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)Decref chunks
decref_tileables(tileable_keys)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)Incref chunks.
incref_tileables(tileable_keys)Incref tileables.
track(tileable_key, chunk_keys)Track tileable.