trinity.utils.dlc_utils module# class trinity.utils.dlc_utils.ClusterStatus[源代码]# 基类：object __init__()[源代码]# finish() → None[源代码]# running() → bool[源代码]# trinity.utils.dlc_utils.get_dlc_env_vars() → dict[源代码]# trinity.utils.dlc_utils.is_running() → bool[源代码]# Check if ray cluster is running. trinity.utils.dlc_utils.wait_for_ray_setup() → None[源代码]# trinity.utils.dlc_utils.wait_for_ray_worker_nodes(world_size: int) → None[源代码]# trinity.utils.dlc_utils.setup_ray_cluster(namespace: str) → str[源代码]# Setup a ray cluster in DLC environment. This function will start a ray cluster if it is not running, otherwise it will reuse the existing ray cluster. 返回: The address of the ray cluster. 返回类型: str trinity.utils.dlc_utils.stop_ray_cluster(namespace: str)[源代码]# Stop the ray cluster by sending a signal to the cluster status actor.
