Method _run_parallel

ci/lint/orchestrator.py:65–127

Run stages in parallel with ThreadPoolExecutor.

(self)

                shutil.rmtree(self.tmpdir, ignore_errors=True)

    def _run_parallel(self) -> bool:
        """Run stages in parallel with ThreadPoolExecutor."""
        assert self.tmpdir is not None, "tmpdir must be initialized before running"

        print("")
        print(f"⚡ PARALLEL LINTING ({len(self.stages)} stages)")
        print("================================")

        parallel_start = time.time()
        failed_stages: list[str] = []

        # Use ThreadPoolExecutor for I/O-bound workloads
        with ThreadPoolExecutor(max_workers=len(self.stages)) as executor:
            # Submit all stages (respecting dependencies)
            for stage in self.stages:
                future = executor.submit(self._run_stage_parallel, stage)
                self.stage_futures[stage.name] = future
                print(f"  Started {stage.name} (PID {os.getpid()})")

            print("")

            # Wait for all stages to complete
            for stage in self.stages:
                if is_interrupted():
                    print("\n⚠️  Interrupted - stopping all stages")
                    failed_stages.append(stage.name)
                    continue

                future = self.stage_futures[stage.name]
                try:
                    success, _ = future.result(timeout=stage.timeout)
                    if success:
                        print(f"  ✅ {stage.name} completed")
                    else:
                        print(f"  ❌ {stage.name} FAILED")
                        failed_stages.append(stage.name)
                except TimeoutError:
                    print(f"  ❌ {stage.name} TIMEOUT (>{stage.timeout}s)")
                    failed_stages.append(stage.name)
                except KeyboardInterrupt:
                    _thread.interrupt_main()
                    raise
                except Exception as e:
                    print(f"  ❌ {stage.name} ERROR: {e}")
                    failed_stages.append(stage.name)

        parallel_duration = time.time() - parallel_start
        print("")
        print(f"  Parallel phase completed in {int(parallel_duration)}s")

        # Print captured output from each stage
        for stage in self.stages:
            logfile = self.tmpdir / f"{stage.name}.log"
            if logfile.exists():
                print("")
                print(f"--- {stage.name} output ---")
                print(logfile.read_text())