mars.services.task.WebTaskAPI¶
- class mars.services.task.WebTaskAPI(session_id: str, address: str, request_rewriter: Optional[Callable] = None)[source]¶
-
Methods
__init__
(session_id, address[, request_rewriter])cancel_task
(task_id)Cancel task.
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_details
(task_id)get_tileable_graph_as_json
(task_id)get_tileable_subtasks
(task_id, tileable_id, ...)submit_tileable_graph
(graph[, task_name, ...])Submit a tileable graph
wait_task
(task_id[, timeout])Wait for a task to finish.
Attributes
request_rewriter