mars.services.subtask.SubtaskAPI#

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