mars.services.subtask.SubtaskAPI#

class mars.services.subtask.SubtaskAPI(address: 字符串)[来源]#
__init__(address: 字符串)[来源]#

方法

__init__(地址)

cancel_subtask_in_slot(band_name, slot_id)

取消在工作者插槽中运行的子任务并等待其被取消

create(address)

run_subtask_in_slot(band_name, slot_id, subtask)

在当前工作节点运行子任务

set_running_operand_progress(session_id, ...)