PContext

class tensorplay.distributed.elastic.multiprocessing.PContext(name: str, entrypoint: ~collections.abc.Callable | str, args: tuple, envs: dict[int, dict[str, str]], logs_specs: ~tensorplay.distributed.elastic.multiprocessing.api.LogsSpecs | None = None, log_dir: str | None = None, redirects: ~tensorplay.distributed.elastic.multiprocessing.redirects.Std | dict[int, ~tensorplay.distributed.elastic.multiprocessing.redirects.Std] = <Std.NONE: 0>, tee: ~tensorplay.distributed.elastic.multiprocessing.redirects.Std | dict[int, ~tensorplay.distributed.elastic.multiprocessing.redirects.Std] = <Std.NONE: 0>, log_line_prefixes: dict[int, str] | None = None, duplicate_stdout_filters: list[str] | None = None, duplicate_stderr_filters: list[str] | None = None)[source]

Base class owning a homogeneous group of worker processes.

close(death_sig: Signals | None = None, timeout: int = 30) → None[source]

Terminate all workers with death_sig, escalating to kill.

poll() → RunProcsResult | None[source]

Return the terminal result, or None while workers are running.

start() → None[source]

Launch all workers.

wait(timeout: float = -1, period: float = 1) → RunProcsResult | None[source]

Block until completion (or timeout seconds); returns the result.