Nigthly Fix for Slow Tests

scripts/tests/run_python_test.py

@@ -319,6 +319,13 @@ def main_impl(app: str, factory_reset: bool, factory_reset_app_only: bool, app_a
             daemon=True)
         restart_monitor_thread.start()
 
+    split_args = shlex.split(script_args)
+    timeout_key = '--timeout'
+    timeout_index = split_args.index(timeout_key) if timeout_key in split_args else None
+    test_arg_timeout = None
+    if timeout_index is not None:
+        test_arg_timeout = int(split_args[timeout_index+1])
+
     # TODO: Remove this below workaround once we understand if mobile-device-test needs to be run through Cirque and through this script for CI test pipeline, task PR: https://github.com/project-chip/matter-test-scripts/issues/681
     if "mobile-device-test.py" not in script:
         script_args += f" --restart-flag-file {restart_flag_file}"
@@ -350,7 +357,13 @@ def main_impl(app: str, factory_reset: bool, factory_reset_app_only: bool, app_a
     test_script_process.p.stdin.close()
 
     try:
-        test_script_exit_code = test_script_process.wait()
+        # Some tests have very large execution time (Nightly jobs), we use the --timeout to avoid test to use default timeout
+        if test_arg_timeout is None:
+            # This will use the DEFAULT_TIMEOUT_S
+            test_script_exit_code = test_script_process.wait()
+        else:
+            log.info("Executing the test with a timeout of %d seconds", test_arg_timeout)
+            test_script_exit_code = test_script_process.wait(timeout=test_arg_timeout)
 
         if test_script_exit_code != 0:
             log.error("Test script exited with returncode %d", test_script_exit_code)

src/python_testing/matter_testing_infrastructure/matter/testing/tasks.py

@@ -71,7 +71,7 @@ class Subprocess(threading.Thread):
     """Run a subprocess in a thread."""
 
     DEFAULT_TIMEOUT_S: float = 300.0
-    TERMINATION_TIMEOUT_S: float = 5.0
+    TERMINATION_TIMEOUT_S: float = 10.0
 
     def __init__(self, program: str, *args: str, output_cb: Callable[[bytes, bool], bytes] | None = None,
                  f_stdout: BinaryIO = sys.stdout.buffer, f_stderr: BinaryIO = sys.stderr.buffer) -> None:
@@ -217,4 +217,8 @@ def terminate(self) -> None:
     def wait(self, timeout: float = DEFAULT_TIMEOUT_S) -> int | None:
         """Wait for the subprocess to finish."""
         self.join(timeout)
+        # join() does not return a value, so we call is_alive(), if is alive this mean it timed out.
+        if self.is_alive():
+            # Terminate the process to get a returncode
+            self.terminate()
         return self.returncode