mars.services.scheduling.SchedulingAPI¶
- class mars.services.scheduling.SchedulingAPI(session_id: str, address: str, manager_ref=None, queueing_ref=None)[source]¶
-
Methods
__init__(session_id, address[, manager_ref, ...])add_subtasks(subtasks[, priorities])Submit subtasks into scheduling service
cancel_subtasks(subtask_ids[, kill_timeout])Cancel pending and running subtasks.
create(session_id, address)finish_subtasks(subtask_ids[, schedule_next])Mark subtasks as finished, letting scheduling service to schedule next tasks in the ready queue
get_subtask_schedule_summaries([task_id])Get details of scheduling for tasks
update_subtask_priority(subtask_id, priority)Update priorities of subtasks