diff --git a/pyproject.toml b/pyproject.toml index c7599b9..4206c78 100644 --- a/pyproject.toml +++ b/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 "] readme = "README.md" diff --git a/redisbench_admin/run/cluster.py b/redisbench_admin/run/cluster.py index 82bcd84..63eb357 100644 --- a/redisbench_admin/run/cluster.py +++ b/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 =)!!" ) diff --git a/redisbench_admin/run_remote/run_remote.py b/redisbench_admin/run_remote/run_remote.py index bd5e17c..2b07975 100644 --- a/redisbench_admin/run_remote/run_remote.py +++ b/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,