mars.services.cluster.WebClusterAPI#
- class mars.services.cluster.WebClusterAPI(address: str, request_rewriter: Optional[Callable] = None)[source]#
-
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