mars.services.subtask.SubtaskAPI¶
- class mars.services.subtask.SubtaskAPI(address: str)[source]¶
-
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, …)