Fix prepare_vector_db method

Author: mpozniak95

redis_benchmarks_specification/__self_contained_coordinator__/clients.py

@@ -25,26 +25,24 @@ def prepare_memtier_benchmark_parameters(
 
 
 def prepare_vector_db_benchmark_parameters(
-    clientconfig,
-    full_benchmark_path,
-    port,
-    server,
+    clientconfig, full_benchmark_path, port, server, password, client_mnt_point
 ):
     benchmark_command = []
-    if port is not None:
-        benchmark_command.extend(["REDIS_PORT={}".format(port)])
+    # if port is not None:
+    #     benchmark_command.extend(["REDIS_PORT={}".format(port)])
+    # if password is not None:
+    #     benchmark_command.extend(["REDIS_AUTH={}".format(password)])
     benchmark_command.extend(
         [
             full_benchmark_path,
             "--host",
             f"{server}",
         ]
     )
-    benchmark_command.extend(
-        ["--engines", clientconfig.get("engines", "redis-test")]
-    )
+    benchmark_command.extend(["--engines", clientconfig.get("engines", "redis-test")])
     benchmark_command.extend(
         ["--datasets", clientconfig.get("datasets", "glove-100-angular")]
     )
     benchmark_command_str = " ".join(benchmark_command)
+    benchmark_command_str = f"bash -c 'ITERATIONS=1 {benchmark_command_str} && mv /code/results {client_mnt_point}.'"
     return None, benchmark_command_str

redis_benchmarks_specification/__self_contained_coordinator__/self_contained_coordinator.py

@@ -59,7 +59,6 @@
 from redis_benchmarks_specification.__runner__.runner import (
     print_results_table_stdout,
     prepare_memtier_benchmark_parameters,
-    prepare_vector_db_benchmark_parameters,
 )
 from redis_benchmarks_specification.__self_contained_coordinator__.args import (
     create_self_contained_coordinator_args,
@@ -112,6 +111,9 @@
     extract_db_cpu_limit,
     generate_cpuset_cpus,
 )
+from redis_benchmarks_specification.__self_contained_coordinator__.clients import (
+    prepare_vector_db_benchmark_parameters,
+)
 from redis_benchmarks_specification.__self_contained_coordinator__.docker import (
     generate_standalone_redis_server_args,
 )