trinity.utils.dlc_utils module

class trinity.utils.dlc_utils.ClusterStatus[source]

Bases: object

__init__()[source]
finish() → None[source]
running() → bool[source]
trinity.utils.dlc_utils.get_dlc_env_vars() → dict[source]
trinity.utils.dlc_utils.is_running() → bool[source]

Check if ray cluster is running.

trinity.utils.dlc_utils.wait_for_ray_setup() → None[source]
trinity.utils.dlc_utils.wait_for_ray_worker_nodes(world_size: int) → None[source]
trinity.utils.dlc_utils.setup_ray_cluster(namespace: str, envs: dict)[source]
trinity.utils.dlc_utils.stop_ray_cluster(namespace: str)[source]

Stop the ray cluster by sending a signal to the cluster status actor.