Method _process_active_tests

ci/util/running_process_group.py:559–627

Process active tests, return True if any activity occurred.

(
        self,
        active_processes: list[RunningProcess],
        exit_failed_processes: list[tuple[RunningProcess, int]],
        failed_processes: list[str],
        completed_timings: list[ProcessTiming],
        stuck_monitor: Optional[ProcessStuckMonitor],
    )

        return failures

    def _process_active_tests(
        self,
        active_processes: list[RunningProcess],
        exit_failed_processes: list[tuple[RunningProcess, int]],
        failed_processes: list[str],
        completed_timings: list[ProcessTiming],
        stuck_monitor: Optional[ProcessStuckMonitor],
    ) -> bool:
        """Process active tests, return True if any activity occurred."""
        any_activity = False

        # Iterate backwards to safely remove processes from the list
        for i in range(len(active_processes) - 1, -1, -1):
            proc = active_processes[i]

            if self.config.verbose:
                with proc.line_iter(timeout=60) as line_iter:
                    for line in line_iter:
                        print(line)
                        any_activity = True

            # Check if process has finished
            if proc.finished:
                any_activity = True
                # Get the exit code to check for failure
                exit_code = cast(int, proc.wait())

                # Process completed, remove from active list
                active_processes.remove(proc)
                # Stop monitoring this process
                if stuck_monitor:
                    stuck_monitor.stop_monitoring(proc)

                # Collect timing data
                if proc.duration is not None:
                    timing = ProcessTiming(
                        name=_get_friendly_test_name(proc.command),
                        duration=proc.duration,
                        command=str(proc.command),
                    )
                    completed_timings.append(timing)

                # Check for non-zero exit code (failure)
                if exit_code != 0:
                    print(
                        f"Process failed with exit code {exit_code}: {proc.command}",
                        flush=True,
                    )
                    exit_failed_processes.append((proc, exit_code))
                    # Early abort if we reached the failure threshold
                    if (
                        len(exit_failed_processes) + len(failed_processes)
                    ) >= self.config.max_failures_before_abort:
                        print(
                            f"\nExceeded failure threshold ({self.config.max_failures_before_abort}). Aborting remaining tests."
                        )
                        # Kill remaining active processes
                        for p in active_processes: