@@ -203,6 +203,27 @@ def run_client_runner_logic(args, project_name, project_name_suffix, project_ver
203
203
override_memtier_test_time ,
204
204
)
205
205
206
+ def prepare_vector_db_benchmark_parameters (
207
+ clientconfig ,
208
+ full_benchmark_path ,
209
+ port ,
210
+ server ,
211
+ password ,
212
+ ):
213
+ benchmark_command = []
214
+ if port is not None :
215
+ benchmark_command .extend (["REDIS_PORT={}" .format (port )])
216
+ if password is not None :
217
+ benchmark_command .extend (["REDIS_AUTH={}" .format (password )])
218
+ benchmark_command .extend ([
219
+ full_benchmark_path ,
220
+ "--host" ,
221
+ f"{ server } " ,
222
+ ])
223
+ benchmark_command .extend (["--engines" , clientconfig .get ("engines" , "redis-m-8-ef-16" )])
224
+ benchmark_command .extend (["--datasets" , clientconfig .get ("datasets" , "glove-100-angular" )])
225
+ benchmark_command_str = " " .join (benchmark_command )
226
+ return None , benchmark_command_str
206
227
207
228
def prepare_memtier_benchmark_parameters (
208
229
clientconfig ,
@@ -699,22 +720,7 @@ def delete_temporary_files(
699
720
)
700
721
arbitrary_command = False
701
722
702
- if "memtier_benchmark" not in benchmark_tool :
703
- # prepare the benchmark command
704
- (
705
- benchmark_command ,
706
- benchmark_command_str ,
707
- ) = prepare_benchmark_parameters (
708
- benchmark_config ,
709
- full_benchmark_path ,
710
- port ,
711
- host ,
712
- local_benchmark_output_filename ,
713
- False ,
714
- benchmark_tool_workdir ,
715
- False ,
716
- )
717
- else :
723
+ if "memtier_benchmark" in benchmark_tool :
718
724
(
719
725
_ ,
720
726
benchmark_command_str ,
@@ -736,6 +742,33 @@ def delete_temporary_files(
736
742
override_memtier_test_time ,
737
743
override_test_runs ,
738
744
)
745
+ elif "vector_db_benchmark" in benchmark_tool :
746
+ (
747
+ _ ,
748
+ benchmark_command_str ,
749
+ ) = prepare_vector_db_benchmark_parameters (
750
+ benchmark_config ["clientconfig" ],
751
+ full_benchmark_path ,
752
+ port ,
753
+ host ,
754
+ password ,
755
+ )
756
+ else :
757
+ # prepare the benchmark command
758
+ (
759
+ benchmark_command ,
760
+ benchmark_command_str ,
761
+ ) = prepare_benchmark_parameters (
762
+ benchmark_config ,
763
+ full_benchmark_path ,
764
+ port ,
765
+ host ,
766
+ local_benchmark_output_filename ,
767
+ False ,
768
+ benchmark_tool_workdir ,
769
+ False ,
770
+ )
771
+
739
772
740
773
if (
741
774
arbitrary_command
0 commit comments