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)create_session(session_id, address[, …])destroy_session(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