INNER CODE UNIT · Python

_spawn_workers

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

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",
        "--processes",
        str(workers),
        "--threads",
        "1",
        "--first-port",
        str(first_port),
        sys.executable,
        "-m",
        "serviette.cli",
        "indexer",
        *argv,

View source record →