mars.services.cluster.ClusterAPI¶

class mars.services.cluster.ClusterAPI(address: str)[source]¶

Methods

`__init__`(address)
`create`(address)
`get_all_bands`([role, statuses, exclude_statuses])	Get all bands that can be used for computation.
`get_bands`()	Get bands that can be used for computation on current node.
`get_mars_versions`()	Get versions used in current Mars cluster
`get_nodes_info`([nodes, role, env, resource, …])	Get worker info
`get_supervisor_refs`(uids)	Get actor references hosting the specified actor uid
`get_supervisors`([filter_ready])	Get supervisor addresses
`get_supervisors_by_keys`(keys)	Get supervisor address hosting the specified key
`mark_node_ready`()	Mark current node ready for work loads
`set_band_quota_info`(band_name, quota_info)
`set_band_slot_infos`(band_name, slot_infos)
`set_band_storage_info`(band_name, storage_info)
`set_node_disk_info`(disk_info)
`set_node_status`(node, role, status)	Set status of node
`wait_all_supervisors_ready`()	Wait till all expected supervisors are ready
`wait_node_ready`()	Wait current node to be ready
`watch_all_bands`([role, version, statuses, …])	Watch all bands that can be used for computation.
`watch_nodes`(role[, env, resource, detail, …])	Watch changes of workers
`watch_supervisor_refs`(uids)
`watch_supervisors`([version])	Watch supervisor addresses
`watch_supervisors_by_keys`(keys[, version])