Added deployment_name zsets (#328)

Author: filipecosta90

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "redisbench-admin"
-version = "0.7.22"
+version = "0.7.23"
 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]>","Redis Performance Group <[email protected]>"]
 readme = "README.md"

redisbench_admin/compare/compare.py

@@ -93,6 +93,7 @@ def compare_command_logic(args, project_name, project_version):
     (
         prefix,
         testcases_setname,
+        _,
         tsname_project_total_failures,
         tsname_project_total_success,
         _,

redisbench_admin/run/redistimeseries.py

@@ -358,6 +358,7 @@ def update_secondary_result_keys(
     (
         _,
         testcases_setname,
+        deployment_name_zsetname,
         _,
         tsname_project_total_success,
         running_platforms_setname,
@@ -378,7 +379,15 @@ def update_secondary_result_keys(
         test_name,
     )
     try:
+        rts.zadd(deployment_name_zsetname, {deployment_name: start_time_ms})
         if test_name is not None:
+            deployment_name_zsetname_testnames = (
+                deployment_name_zsetname
+                + "{}:deployment_name={}".format(
+                    deployment_name_zsetname, deployment_name
+                )
+            )
+            rts.zadd(deployment_name_zsetname_testnames, {test_name: start_time_ms})
             rts.sadd(testcases_setname, test_name)
             testcases_zsetname = testcases_setname + ":zset"
             rts.zadd(testcases_zsetname, {test_name: start_time_ms})

redisbench_admin/run_remote/run_remote.py

@@ -155,6 +155,7 @@ def run_remote_command_logic(args, project_name, project_version):
     remote_envs = {}
     dirname = "."
     (
+        _,
         _,
         _,
         tsname_project_total_failures,

redisbench_admin/utils/remote.py

@@ -988,6 +988,7 @@ def get_overall_dashboard_keynames(
         )
     )
     testcases_setname = "{}:testcases".format(sprefix)
+    deployment_name_setname = "{}:deployment_names".format(sprefix)
     project_archs_setname = "{}:archs".format(sprefix)
     project_oss_setname = "{}:oss".format(sprefix)
     project_branches_setname = "{}:branches".format(sprefix)
@@ -1024,6 +1025,7 @@ def get_overall_dashboard_keynames(
     return (
         prefix,
         testcases_setname,
+        deployment_name_setname,
         tsname_project_total_failures,
         tsname_project_total_success,
         running_platforms_setname,

tests/test_aa_run_remote.py

@@ -96,6 +96,7 @@ def test_get_overall_dashboard_keynames():
     (
         prefix,
         testcases_setname,
+        deployment_name_setname,
         tsname_project_total_failures,
         tsname_project_total_success,
         _,
@@ -121,6 +122,7 @@ def test_get_overall_dashboard_keynames():
     (
         prefix,
         testcases_setname,
+        deployment_name_setname,
         tsname_project_total_failures,
         tsname_project_total_success,
         running_platforms_setname,

tests/test_redistimeseries.py

@@ -47,6 +47,7 @@ def test_timeseries_test_sucess_flow():
                 (
                     prefix,
                     testcases_setname,
+                    deployment_name_setname,
                     tsname_project_total_failures,
                     tsname_project_total_success,
                     running_platforms_setname,
@@ -100,6 +101,7 @@ def test_timeseries_test_sucess_flow():
 
             assert rts.exists(testcases_and_metric_context_path_setname)
             assert rts.exists(testcases_metric_context_path_setname)
+            assert rts.exists(deployment_name_setname)
             testcases_zsetname = testcases_setname + ":zset"
             testcases_zsetname_component_search = (
                 testcases_setname + ":zset:component:search"
@@ -109,6 +111,7 @@ def test_timeseries_test_sucess_flow():
             assert rts.zcard(testcases_zsetname)
             assert rts.zcard(testcases_zsetname_component_search)
             assert test_name.encode() in rts.zpopmin(testcases_zsetname)[0][0]
+            assert deployment_name.encode() in rts.zpopmin(deployment_name_setname)[0][0]
             assert rts.exists(testcases_zsetname_component_search)
             assert (
                 test_name.encode()

tests/test_remote.py

@@ -277,6 +277,7 @@ def test_exporter_create_ts():
                 (
                     prefix,
                     testcases_setname,
+                    deployment_name_setname,
                     tsname_project_total_failures,
                     tsname_project_total_success,
                     running_platforms_setname,