in rally-custom/custom_tracks/opensearch/so_vector/track.py [0:0]
def load_query_vectors(queries_file) -> Dict[int, List[float]]:
if not (os.path.exists(queries_file) and os.path.isfile(queries_file)):
raise ValueError(f"Provided queries file '{queries_file}' does not exist or is not a file")
query_vectors: Dict[int, List[float]]
with open(queries_file, "r") as f:
logger.debug(f"Reading query vectors from '{queries_file}'")
lines = f.readlines()
query_vectors = {_index: json.loads(vector) for _index, vector in enumerate(lines)}
logger.debug(f"Finished reading query vectors from '{queries_file}'")
return query_vectors