mars.services.cluster.WebClusterAPI

class mars.services.cluster.WebClusterAPI(address: str, request_rewriter: Optional[Callable] = None)

__init__(address: str, request_rewriter: Optional[Callable] = None)

Methods

__init__(address[, request_rewriter])
get_all_bands([role, statuses, exclude_statuses])	Get all bands that can be used for computation.
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_supervisors([filter_ready])	Get supervisor addresses
watch_all_bands([role, statuses, ...])	Watch all bands that can be used for computation.
watch_nodes(role[, env, resource, detail, ...])	Watch changes of workers
watch_supervisors([version])	Watch supervisor addresses

Attributes

request_rewriter