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])