in rally-custom/custom_tracks/elasticsearch/openai_vector/track.py [0:0]
def __init__(self, track, params, **kwargs):
if len(track.indices) == 1:
default_index = track.indices[0].name
else:
default_index = "_all"
self._index_name = params.get("index", default_index)
self._cache = params.get("cache", False)
self._params = params
self._queries = []
cwd = os.path.dirname(__file__)
with bz2.open(os.path.join(cwd, QUERIES_FILENAME), "r") as queries_file:
for vector_query in queries_file:
self._queries.append(json.loads(vector_query))
self._iters = 0
self._maxIters = len(self._queries)
self.infinite = True