mars.services.cluster.AbstractClusterBackend#

class mars.services.cluster.AbstractClusterBackend[source]#

Methods

`__init__`()
`create`(node_role, lookup_address, pool_address)	param node_role
`get_supervisors`([filter_ready])	Get list of supervisors
`reconstruct_worker`(address)	Reconstruct a worker
`release_worker`(address)	Return a worker
`request_worker`([worker_cpu, worker_mem, timeout])	Create a new worker
`watch_supervisors`()	Watch changes of supervisors

Attributes

name