added filtering by platform (#238)

* added filtering by platform

* ran formatting and fixed an error

* fixed issue after runnig poetry flake8

Author: slice4e

redis_benchmarks_specification/__builder__/builder.py

@@ -353,6 +353,8 @@ def builder_process_stream(
                         "{}_len_bytes".format(artifact)
                     ] = bin_artifact_len
                 result = True
+                if b"platform" in testDetails:
+                    build_stream_fields["platform"] = testDetails[b"platform"]
                 if result is True:
                     stream_id = conn.xadd(
                         STREAM_KEYNAME_NEW_BUILD_EVENTS, build_stream_fields

redis_benchmarks_specification/__cli__/args.py

@@ -130,4 +130,10 @@ def spec_cli_args(parser):
         default=-1,
         help="Use the last N samples. by default will use all available values",
     )
+    parser.add_argument(
+        "--platform",
+        type=str,
+        default="",
+        help="Only trigger tests on the specified platform.",
+    )
     return parser

redis_benchmarks_specification/__cli__/cli.py

@@ -197,6 +197,8 @@ def trigger_tests_cli_command_logic(args, project_name, project_version):
     logging.info(
         "Will trigger {} distinct tests {}.".format(len(commits), by_description)
     )
+    if args.platform:
+        logging.info("Will trigger tests only for platform {}".format(args.platform))
 
     hash_regexp = args.hash_regexp
     if hash_regexp == ".*":
@@ -250,6 +252,8 @@ def trigger_tests_cli_command_logic(args, project_name, project_version):
                 ) = get_commit_dict_from_sha(
                     cdict["git_hash"], "redis", "redis", cdict, True, args.gh_token
                 )
+                if args.platform:
+                    commit_dict["platform"] = args.platform
                 if result is True:
                     stream_id = "n/a"
                     if args.dry_run is False:

redis_benchmarks_specification/__self_contained_coordinator__/self_contained_coordinator.py

@@ -433,7 +433,26 @@ def process_self_contained_coordinator_stream(
                 run_arch,
             ) = extract_build_info_from_streamdata(testDetails)
 
-            if run_arch == arch:
+            skip_test = False
+            if b"platform" in testDetails:
+                platform = testDetails[b"platform"]
+                if running_platform != platform:
+                    skip_test = True
+                    logging.info(
+                        "skipping stream_id {} given plaform {}!={}".format(
+                            stream_id, running_platform, platform
+                        )
+                    )
+
+            if run_arch != arch:
+                skip_test = True
+                logging.info(
+                    "skipping stream_id {} given arch {}!={}".format(
+                        stream_id, run_arch, arch
+                    )
+                )
+
+            if skip_test is False:
                 overall_result = True
                 profiler_dashboard_links = []
                 if docker_air_gap:
@@ -951,12 +970,6 @@ def process_self_contained_coordinator_stream(
 
                             overall_result &= test_result
 
-            else:
-                logging.info(
-                    "skipping stream_id {} given arch {}!={}".format(
-                        stream_id, run_arch, arch
-                    )
-                )
         else:
             logging.error("Missing commit information within received message.")
     except: