def METHOD_NAME(self, queries_data, topk, logger=None):
    chunked_queries = utils.chunk_it(queries_data, self.num_threads)
    for idx, arg in enumerate(self.arguments):
        arg["queries_data"] = chunked_queries[idx]
        arg["topk"] = topk
        arg["logger"] = logger