mars.services.cluster.WebClusterAPI

class mars.services.cluster.WebClusterAPI(address: str)[source]
__init__(address: str)[source]

Methods

__init__(address)

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_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