Function _handle_process_completion

ci/util/test_runner.py:1116–1239

Handle completion of a single test process Args: proc_state: State information for the completed process active_processes: List of currently active processes completed_timings: List to collect timing data last_activity_time: Dictionary tracking activity time

(
    proc_state: ProcessState,
    active_processes: list[RunningProcess],
    completed_timings: list[ProcessTiming],
    last_activity_time: dict[RunningProcess, float],
)

def _handle_process_completion(
    proc_state: ProcessState,
    active_processes: list[RunningProcess],
    completed_timings: list[ProcessTiming],
    last_activity_time: dict[RunningProcess, float],
) -> None:
    """
    Handle completion of a single test process

    Args:
        proc_state: State information for the completed process
        active_processes: List of currently active processes
        completed_timings: List to collect timing data
        last_activity_time: Dictionary tracking activity times

    Raises:
        TestExecutionFailedException: If process failed
    """
    proc = proc_state.process
    cmd = proc_state.command
    if isinstance(cmd, list):
        cmd = subprocess.list2cmdline(cmd)

    try:
        returncode = proc.wait()
        if returncode != 0:
            test_name = _extract_test_name(cmd)
            ts_print(f"\nCommand failed: {cmd} with return code {returncode}")
            ts_print("\033[91m###### ERROR ######\033[0m")
            ts_print(f"Test failed: {test_name}")

            # Capture the actual output from the failed process
            try:
                actual_output = proc.stdout
                if actual_output.strip():
                    ts_print("\n=== ACTUAL OUTPUT FROM FAILED PROCESS ===")
                    ts_print(actual_output)
                    ts_print("=== END OF OUTPUT ===")
                else:
                    actual_output = "No output captured from failed process"
            except KeyboardInterrupt as ki:
                handle_keyboard_interrupt(ki)
                raise
            except Exception as e:
                actual_output = f"Error capturing output: {e}"

            # Flush output for real-time visibility (but avoid on Windows due to blocking issues)
            if os.name != "nt":  # Only flush on non-Windows systems
                sys.stdout.flush()
            for p in active_processes:
                if p != proc:
                    p.kill()
            failure = TestFailureInfo(
                test_name=test_name,
                command=str(cmd),
                return_code=returncode,
                output=actual_output,
                error_type="command_failure",