Fixed formatting

Author: fcostaoliveira

redis_benchmarks_specification/__cli__/stats.py

@@ -272,7 +272,9 @@ def generate_stats_cli_command_logic(args, project_name, project_version):
                     benchmark_config["tested-commands"] = tested_commands
                     logging.warn(
                         "there is a difference between specified test-commands in the yaml (name={}) and the ones we've detected {}!={}".format(
-                            test_name, sorted(origin_tested_commands), sorted(tested_commands)
+                            test_name,
+                            sorted(origin_tested_commands),
+                            sorted(tested_commands),
                         )
                     )
 
@@ -333,7 +335,9 @@ def generate_stats_cli_command_logic(args, project_name, project_version):
                     benchmark_config["tested-groups"] = tested_groups
                     logging.warn(
                         "there is a difference between specified test-groups in the yaml (name={}) and the ones we've detected {}!={}".format(
-                            test_name, sorted(origin_tested_groups), sorted(tested_groups)
+                            test_name,
+                            sorted(origin_tested_groups),
+                            sorted(tested_groups),
                         )
                     )
 

redis_benchmarks_specification/__common__/runner.py

@@ -67,7 +67,9 @@ def execute_init_commands(benchmark_config, r, dbconfig_keyname="dbconfig"):
 
         for lua_script in lua_scripts:
             try:
-                logging.info("Executing Lua script (length: {} chars)".format(len(lua_script)))
+                logging.info(
+                    "Executing Lua script (length: {} chars)".format(len(lua_script))
+                )
                 # Execute the Lua script using EVAL command with 0 keys
                 stdout = r.execute_command("EVAL", lua_script, 0)
                 logging.info("Lua script result: {}".format(stdout))
@@ -137,7 +139,6 @@ def extract_testsuites(args):
     return testsuite_spec_files
 
 
-
 def commandstats_latencystats_process_name(
     metric_name, prefix, setup_name, variant_labels_dict
 ):
@@ -235,6 +236,7 @@ def collect_redis_metrics(
 
     return start_time_ms, res, kv_overall
 
+
 def export_redis_metrics(
     artifact_version,
     end_time_ms,
@@ -274,9 +276,7 @@ def export_redis_metrics(
             "branch": tf_github_branch
         }
     if git_hash is not None and git_hash != "":
-        by_variants["by.hash/{}".format(git_hash)] = {
-            "hash": git_hash
-        }
+        by_variants["by.hash/{}".format(git_hash)] = {"hash": git_hash}
     if artifact_version is not None and artifact_version != "":
         by_variants["by.version/{}".format(artifact_version)] = {
             "version": artifact_version
@@ -339,8 +339,6 @@ def export_redis_metrics(
     return datapoint_errors, datapoint_inserts
 
 
-
-
 def reset_commandstats(redis_conns):
     for pos, redis_conn in enumerate(redis_conns):
         logging.info("Resetting commmandstats for shard {}".format(pos))
@@ -468,7 +466,9 @@ def exporter_datasink_common(
 
     # Update deployment tracking sets
     deployment_type_and_name = f"{setup_type}_AND_{setup_name}"
-    deployment_type_and_name_and_version = f"{setup_type}_AND_{setup_name}_AND_{git_version}"
+    deployment_type_and_name_and_version = (
+        f"{setup_type}_AND_{setup_name}_AND_{git_version}"
+    )
 
     # Add to deployment-specific set (only if datasink connection is available)
     if datasink_conn is not None:
@@ -483,4 +483,6 @@ def exporter_datasink_common(
 
     # Add metadata fields to timeseries metadata
     metadata["deployment_type_AND_deployment_name"] = deployment_type_and_name
-    metadata["deployment_type_AND_deployment_name_AND_version"] = deployment_type_and_name_and_version
+    metadata["deployment_type_AND_deployment_name_AND_version"] = (
+        deployment_type_and_name_and_version
+    )

redis_benchmarks_specification/__compare__/args.py

@@ -76,9 +76,7 @@ def create_compare_arguments(parser):
     parser.add_argument("--baseline_deployment_name", type=str, default="")
     parser.add_argument("--comparison_deployment_name", type=str, default="")
     parser.add_argument("--metric_name", type=str, default="ALL_STATS.Totals.Ops/sec")
-    parser.add_argument(
-        "--running_platform", type=str, default=None
-    )
+    parser.add_argument("--running_platform", type=str, default=None)
     parser.add_argument(
         "--running_platform_baseline",
         type=str,

redis_benchmarks_specification/__compare__/compare.py

@@ -1179,7 +1179,9 @@ def from_rts_to_regression_table(
         if baseline_str != "":
             filters_baseline.append("{}={}".format(by_str_baseline, baseline_str))
         if baseline_deployment_name != "":
-            filters_baseline.append("deployment_name={}".format(baseline_deployment_name))
+            filters_baseline.append(
+                "deployment_name={}".format(baseline_deployment_name)
+            )
         if baseline_github_org != "":
             filters_baseline.append(f"github_org={baseline_github_org}")
         if running_platform_baseline is not None and running_platform_baseline != "":
@@ -1195,14 +1197,19 @@ def from_rts_to_regression_table(
         if comparison_str != "":
             filters_comparison.append("{}={}".format(by_str_comparison, comparison_str))
         if comparison_deployment_name != "":
-            filters_comparison.append("deployment_name={}".format(comparison_deployment_name))
+            filters_comparison.append(
+                "deployment_name={}".format(comparison_deployment_name)
+            )
         if comparison_github_org != "":
             filters_comparison.append(f"github_org={comparison_github_org}")
         if "hash" not in by_str_baseline:
             filters_baseline.append("hash==")
         if "hash" not in by_str_comparison:
             filters_comparison.append("hash==")
-        if running_platform_comparison is not None and running_platform_comparison != "":
+        if (
+            running_platform_comparison is not None
+            and running_platform_comparison != ""
+        ):
             filters_comparison.append(
                 "running_platform={}".format(running_platform_comparison)
             )
@@ -1538,7 +1545,9 @@ def from_rts_to_regression_table(
 
 def get_only_Totals(baseline_timeseries):
     logging.warning("\t\tTime-series: {}".format(", ".join(baseline_timeseries)))
-    logging.info(f"Checking if Totals will reduce timeseries. initial len={len(baseline_timeseries)}")
+    logging.info(
+        f"Checking if Totals will reduce timeseries. initial len={len(baseline_timeseries)}"
+    )
     new_base = []
     for ts_name in baseline_timeseries:
         if "io-threads" in ts_name:
@@ -1548,8 +1557,10 @@ def get_only_Totals(baseline_timeseries):
         if "Totals" in ts_name:
             new_base.append(ts_name)
     baseline_timeseries = new_base
-    logging.info(f"                                          final len={len(baseline_timeseries)}")
- 
+    logging.info(
+        f"                                          final len={len(baseline_timeseries)}"
+    )
+
     return baseline_timeseries
 
 

redis_benchmarks_specification/__runner__/args.py

@@ -44,19 +44,19 @@ def create_client_runner_args(project_name):
         "--deployment_type",
         type=str,
         default="oss-standalone",
-        help="Deployment type for the Redis instance (e.g., oss-standalone, oss-cluster, enterprise)"
+        help="Deployment type for the Redis instance (e.g., oss-standalone, oss-cluster, enterprise)",
     )
     parser.add_argument(
         "--deployment_name",
         type=str,
         default="redis",
-        help="Deployment name identifier for the Redis instance"
+        help="Deployment name identifier for the Redis instance",
     )
     parser.add_argument(
         "--core_count",
         type=int,
         default=None,
-        help="Number of CPU cores available to the Redis instance"
+        help="Number of CPU cores available to the Redis instance",
     )
     parser.add_argument("--github_repo", type=str, default="redis")
     parser.add_argument("--github_org", type=str, default="redis")

redis_benchmarks_specification/__runner__/remote_profiling.py

@@ -238,7 +238,9 @@ def extract_server_metadata_for_timeseries(redis_conn) -> Dict[str, str]:
         else:
             metadata["config_file"] = "none"
 
-        logging.info(f"Extracted {len(metadata)} server metadata fields for timeseries: {list(metadata.keys())}")
+        logging.info(
+            f"Extracted {len(metadata)} server metadata fields for timeseries: {list(metadata.keys())}"
+        )
 
         return metadata