mars.services.task.TaskAPI#
- class mars.services.task.TaskAPI(session_id: str, task_manager_ref: Union[ActorRef, TaskManagerActor])[source]#
-
Methods
__init__(session_id, task_manager_ref)cancel_task(task_id)Cancel task.
create(session_id, address)Create Task API.
get_fetch_tileables(task_id)Get fetch tileable for a task.
get_last_idle_time()Get last idle time from task manager.
get_map_reduce_info(task_id, map_reduce_id)get_task_progress(task_id)Get task progress.
get_task_result(task_id)Get task status.
get_task_results([progress])Get results of all tasks in the session
get_tileable_details(task_id)get_tileable_graph_as_json(task_id)get_tileable_subtasks(task_id, tileable_id, ...)remove_tileables(tileable_keys)set_subtask_result(subtask_result)submit_tileable_graph(graph[, fuse_enabled, ...])Submit a tileable graph
wait_task(task_id[, timeout])Wait for a task to finish.