gigl.distributed.constants#

Attributes#

Functions#

sampling_rpc_init_timeout_seconds()

Tolerance for GLT's cross-rank sampling-worker RPC gather, in seconds.

sampling_worker_init_timeout_seconds()

Bound on how long a rank waits for its own sampling workers to reach the init barrier.

Module Contents#

gigl.distributed.constants.sampling_rpc_init_timeout_seconds()[source]#

Tolerance for GLT’s cross-rank sampling-worker RPC gather, in seconds.

Raise this when ranks can legitimately reach loader construction more than the default apart – e.g. a run whose CSR assembly has a slow single-rank fallback path.

Return type:

int

gigl.distributed.constants.sampling_worker_init_timeout_seconds()[source]#

Bound on how long a rank waits for its own sampling workers to reach the init barrier.

Derived from the gather tolerance rather than configured separately, so raising GIGL_SAMPLING_RPC_INIT_TIMEOUT_SECONDS moves both bounds coherently.

Return type:

int

gigl.distributed.constants.DEFAULT_MASTER_DATA_BUILDING_PORT = 30000[source]#
gigl.distributed.constants.DEFAULT_MASTER_INFERENCE_PORT = 10000[source]#
gigl.distributed.constants.DEFAULT_MASTER_SAMPLING_PORT = 20000[source]#
gigl.distributed.constants.DEFAULT_SAMPLING_RPC_INIT_TIMEOUT_SECONDS: Final[int] = 600[source]#
gigl.distributed.constants.SAMPLING_RPC_INIT_TIMEOUT_ENV: Final[str] = 'GIGL_SAMPLING_RPC_INIT_TIMEOUT_SECONDS'[source]#
gigl.distributed.constants.SAMPLING_STEADY_STATE_RPC_TIMEOUT_SECONDS: Final[int] = 600[source]#
gigl.distributed.constants.SAMPLING_WORKER_INIT_TIMEOUT_MULTIPLIER: Final[int] = 3[source]#
gigl.distributed.constants.logger[source]#