INNER CODE UNIT · Python

kill_at

pathwaycom/llm-app · serviette/indexer/main.py:74

                kill_at = time.monotonic() + grace
            elif time.monotonic() >= kill_at:
                logger.warning("worker processes did not stop in %.0fs; killing them", grace)
                with contextlib.suppress(ProcessLookupError):
                    os.killpg(proc.pid, signal.SIGKILL)
                return proc.wait()
    finally:
        for sig, handler in previous.items():
            signal.signal(sig, handler)


def _spawn_workers(workers: int, argv: list[str], first_port: int = 10000) -> int:
    logger.info("Spawning %d Pathway worker processes via `pathway spawn`", workers)
    command = [
        sys.executable,
        "-m",
        "pathway",
        "spawn",

View source record →