Method wait_for

server/scripts/phase_split_dual_gpu.py:100–111

(self, needle: str, timeout_s: float)

        self._thread.start()

    def wait_for(self, needle: str, timeout_s: float) -> None:
        deadline = time.time() + timeout_s
        tail: list[str] = []
        while time.time() < deadline:
            try:
                line = self.queue.get(timeout=0.2)
                tail.append(line)
                if needle in line:
                    return
            except queue.Empty:
                pass
        raise TimeoutError(f"timed out waiting for {needle!r}; tail={tail[-12:]}")


class PFlashDaemon: