mars.services.lifecycle.LifecycleAPI#

class mars.services.lifecycle.LifecycleAPI(session_id: str, lifecycle_tracker_ref: Union[mars.services.lifecycle.supervisor.tracker.LifecycleTrackerActor, mars.oscar.core.ActorRef])[source]#
__init__(session_id: str, lifecycle_tracker_ref: Union[mars.services.lifecycle.supervisor.tracker.LifecycleTrackerActor, mars.oscar.core.ActorRef])[source]#

Methods

__init__(session_id, lifecycle_tracker_ref)

batch_track(tileable_key, chunk_keys)

Track tileable.

create(session_id, address)

Create Lifecycle API.

decref_chunks(chunk_keys[, counts])

Decref chunks

decref_tileables(tileable_keys[, counts])

Decref tileables.

get_all_chunk_ref_counts()

Get all chunk keys' ref counts.

get_chunk_ref_counts(chunk_keys)

Get ref counts of chunks.

get_tileable_ref_counts(tileable_keys)

Get ref counts of tileables.

incref_chunks(chunk_keys[, counts])

Incref chunks.

incref_tileables(tileable_keys[, counts])

Incref tileables.

track(tileable_key, chunk_keys)

Track tileable.