mars.services.subtask.SubtaskAPI¶
- class mars.services.subtask.SubtaskAPI(address: str)[源代码]¶
-
Methods
__init__
(address)cancel_subtask_in_slot
(band_name, slot_id)Cancel subtask running in a worker slot and wait until it is cancelled
create
(address)run_subtask_in_slot
(band_name, slot_id, subtask)Run subtask in current worker
set_running_operand_progress
(session_id, ...)