mars.services.task.TaskAPI¶
- class mars.services.task.TaskAPI(session_id: str, task_manager_ref: Union[mars.services.task.supervisor.manager.TaskManagerActor, mars.oscar.core.ActorRef])[源代码]¶
- __init__(session_id: str, task_manager_ref: Union[mars.services.task.supervisor.manager.TaskManagerActor, mars.oscar.core.ActorRef])[源代码]¶
Methods
__init__
(session_id, task_manager_ref)cancel_task
(task_id)Cancel task.
create
(session_id, address)Create Task API.
create_session
(session_id, address)Creating a new task API for the session.
destroy_session
(session_id, address)Destroy a session
get_fetch_tileables
(task_id)Get fetch tileable for a task.
get_last_idle_time
()Get last idle time from task manager.
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_graph_dict_by_task_id
(task_id)set_subtask_result
(subtask_result)submit_tileable_graph
(graph[, task_name, …])Submit a tileable graph
wait_task
(task_id[, timeout])Wait for a task to finish.