mars.services.scheduling.SchedulingAPI¶
- class mars.services.scheduling.SchedulingAPI(session_id: str, address: str, manager_ref=None, queueing_ref=None)[源代码]¶
-
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
update_subtask_priority
(subtask_id, priority)Update priorities of subtasks