Skip to content

Commit a8b3099

Browse files
committed
refactor: Temporarily skip parallel=100 benchmark runs
1 parent 826d5d1 commit a8b3099

File tree

2 files changed

+23
-0
lines changed

2 files changed

+23
-0
lines changed

engine/base_client/search.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,21 @@ def search_all(
7171

7272
search_one = functools.partial(self.__class__._search_one, top=top)
7373

74+
if parallel == 100:
75+
return {
76+
"total_time": 0,
77+
"mean_time": 0,
78+
"mean_precisions": 0,
79+
"std_time": 0,
80+
"min_time": 0,
81+
"max_time": 0,
82+
"rps": 0,
83+
"p95_time": 0,
84+
"p99_time": 0,
85+
"precisions": [],
86+
"latencies": [],
87+
}
88+
7489
if parallel == 1:
7590
start = time.perf_counter()
7691
precisions, latencies = list(

engine/base_client/upload.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,14 @@ def upload(
3838
self.host, distance, self.connection_params, self.upload_params
3939
)
4040

41+
if parallel == 100:
42+
return {
43+
"post_upload": {},
44+
"upload_time": 0,
45+
"total_time": 0,
46+
"latencies": []
47+
}
48+
4149
if parallel == 1:
4250
for batch in iter_batches(tqdm.tqdm(records), batch_size):
4351
latencies.append(self._upload_batch(batch))

0 commit comments

Comments
 (0)