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.