Method receive_worker_message

mypy/build.py:1389–1402

Receive a single message from a worker, with crash diagnostics.

(self, idx: int)

            assert read_tag(buf) == ACK_MESSAGE

    def receive_worker_message(self, idx: int) -> ReadBuffer:
        """Receive a single message from a worker, with crash diagnostics."""
        try:
            return receive(self.workers[idx].conn)
        except OSError as exc:
            try:
                # Give worker process a chance to actually terminate before reporting.
                exit_code = self.workers[idx].proc.wait(timeout=WORKER_SHUTDOWN_TIMEOUT)
            except TimeoutError:
                exit_code = None
            exit_status = f"exit code {exit_code}" if exit_code is not None else "still running"
            raise OSError(
                f"Worker {idx} disconnected before sending data ({exit_status})"
            ) from exc

    def submit(self, graph: Graph, sccs: list[SCC]) -> None:
        """Submit a stale SCC for processing in current process or parallel workers."""