mars.services.task.TaskAPI#
- class mars.services.task.TaskAPI(session_id: 字符串, task_manager_ref: 联合[ActorRef, TaskManagerActor])[来源]#
-
方法
__init__(session_id, task_manager_ref)cancel_task(task_id)取消任务。
create(session_id, address)创建任务API。
get_fetch_tileables(task_id)获取任务的可提取平铺。
get_last_idle_time()从任务管理器获取最后的空闲时间。
get_map_reduce_info(task_id, map_reduce_id)get_task_progress(task_id)获取任务进度。
get_task_result(task_id)获取任务状态。
get_task_results([progress])获取会话中所有任务的结果
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(图[, 融合启用, ...])提交一个可平铺的图形
wait_task(任务ID[, 超时])等待任务完成。