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_node_pool_configs
([address])Get pool configs of a Mars node
get_node_thread_stacks
([address])Get current thread pool stacks of a Mars node
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
reconstruct_worker
(address)release_worker
(address)request_worker
([worker_cpu, worker_mem, timeout])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])