Method _run_parallel

ci/util/running_process_group.py:202–430

Execute processes in parallel (based on test_runner._run_processes_parallel).

(self)

            raise ValueError(f"Unknown execution mode: {self.config.execution_mode}")

    def _run_parallel(self) -> list[ProcessTiming]:
        """Execute processes in parallel (based on test_runner._run_processes_parallel)."""
        if not self.processes:
            return []

        # Create a shared output handler for formatting
        ProcessOutputHandler(verbose=self.config.verbose)

        # Configure Windows console for UTF-8 output if needed
        if os.name == "nt":  # Windows
            if hasattr(sys.stdout, "reconfigure"):
                sys.stdout.reconfigure(encoding="utf-8", errors="replace")  # type: ignore
            if hasattr(sys.stderr, "reconfigure"):
                sys.stderr.reconfigure(encoding="utf-8", errors="replace")  # type: ignore

        # Track start times and enable status monitoring
        self._status_monitoring_active = True
        for proc in self.processes:
            self._track_process_start(proc)

        # Start processes that aren't already running
        for proc in self.processes:
            cmd_str = proc.get_command_str()
            if proc.proc is None:  # Only start if not already running
                proc.start()
                # Create user-friendly display message
                display_msg = cmd_str
                if "meson_example_runner" in cmd_str:
                    # Extract example names from command (after the .py script)
                    parts = cmd_str.split()
                    examples: list[str] = []
                    found_script = False
                    for p in parts:
                        if "meson_example_runner" in p:
                            found_script = True
                            continue
                        if not found_script:
                            continue
                        # Skip flags
                        if p.startswith("-"):
                            continue
                        examples.append(p)
                    if examples:
                        display_msg = f"Compiling: {', '.join(examples)}"
                    else:
                        display_msg = "Compiling examples"
                elif "ci/util/" in cmd_str:
                    display_msg = cmd_str.split("ci/util/")[-1]
                elif "ci\\" in cmd_str or "ci/" in cmd_str:
                    # Extract just the script name
                    parts = cmd_str.replace("\\", "/").split("/")
                    for i, part in enumerate(parts):
                        if part in ("ci", "util") and i + 1 < len(parts):
                            display_msg = "/".join(parts[i:])
                            break
                print(f"{display_msg}", flush=True)
            else:
                print(f"  Already running: {cmd_str}", flush=True)