(query)
| 778 | futures = [] |
| 779 | |
| 780 | def timed_query(query): |
| 781 | start = time.time() |
| 782 | resp = search_sparse_vector(collection, query, top_k) |
| 783 | end = time.time() |
| 784 | latency = (end - start) * 1000.0 |
| 785 | return resp, latency |
| 786 | |
| 787 | for query in query_vectors: |
| 788 | futures.append(executor.submit(timed_query, query)) |
nothing calls this directly
no test coverage detected