[fix] Temporary disable oss-cluster spinning on remote runners (#175)

* [fix] Temporary disable oss-cluster spinning on remote runners

Author: filipecosta90

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "redisbench-admin"
-version = "0.4.2"
+version = "0.4.3"
 description = "Redis benchmark run helper. A wrapper around Redis and Redis Modules benchmark tools ( ftsb_redisearch, memtier_benchmark, redis-benchmark, aibench, etc... )."
 authors = ["filipecosta90 <[email protected]>"]
 readme = "README.md"

redisbench_admin/run/cluster.py

@@ -79,6 +79,6 @@ def spin_up_redis_cluster_remote_redis(
     shard_count,
     port,
 ):
-    raise Exception(
+    logging.error(
         "Remote cluster is still not implemented =(. We're working hard to get it ASAP =)!!"
     )

redisbench_admin/run_remote/run_remote.py

@@ -217,8 +217,13 @@ def run_remote_command_logic(args, project_name, project_version):
                             )
 
                             cluster_api_enabled = False
+                            cluster_start_port = 20000
                             # setup Redis
                             if setup_type == "oss-cluster":
+                                logging.error(
+                                    "Remote cluster is still not implemented =(. We're working hard to get it ASAP =)!!"
+                                )
+                                continue
                                 cluster_api_enabled = True
                                 spin_up_redis_cluster_remote_redis(
                                     benchmark_config,
@@ -233,19 +238,21 @@ def run_remote_command_logic(args, project_name, project_version):
                                     redis_configuration_parameters,
                                     dbdir_folder,
                                     shard_count,
-                                    args.port,
+                                    cluster_start_port,
                                 )
                                 dataset_load_start_time = datetime.datetime.now()
 
                                 # we use node 0 for the checks
                                 local_redis_conn = ssh_tunnel_redisconn(
-                                    args.port,
+                                    cluster_start_port,
                                     server_private_ip,
                                     server_public_ip,
                                     username,
                                 )
                                 r_conns = []
-                                for p in range(args.port, args.port + shard_count):
+                                for p in range(
+                                    cluster_start_port, cluster_start_port + shard_count
+                                ):
                                     local_redis_conn, ssh_tunnel = ssh_tunnel_redisconn(
                                         p,
                                         server_private_ip,