mars.services.scheduling.SchedulingAPI#

class mars.services.scheduling.SchedulingAPI(session_id: str, address: str, manager_ref=None, queueing_ref=None, autoscaler_ref=None)[source]#

__init__(session_id: str, address: str, manager_ref=None, queueing_ref=None, autoscaler_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)
`disable_autoscale_in`()	Disable autoscale in
`finish_subtasks`(subtask_ids[, bands, ...])	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
`try_enable_autoscale_in`()	Try to enable autoscale in, the autoscale-in will be enabled only when last call corresponding disable_autoscale_in has been invoked.
`update_subtask_priority`(subtask_id, priority)	Update priorities of subtasks