Context.submit_subtasks

# within the execute method of a Task:
subtasks = context.submit_subtasks([
    MySubtask(i) for i in range(10)
])
dependent_subtask = context.submit_subtask(
    MyOtherSubtask(), depends_on=subtasks
)

def ExecutionContext.submit_subtasks(
  tasks: Sequence[Task],
  depends_on: FutureTask | list[FutureTask] | None = None,
  cluster: str | None = None,
  max_retries: int = 0,
  optional: bool = False
) -> list[FutureTask]

Submit multiple subtasks from a currently executing task. Same as submit_subtask, but accepts a sequence of tasks.

Parameters

Sequence[Task]

The tasks to submit as subtasks.

FutureTask | list[FutureTask] | None

An optional task or list of tasks already submitted within the same context that the subtasks depend on.

str

An optional cluster slug for running the subtasks. If not provided, the subtasks run on the same cluster as the parent task.

int

Specify the maximum number of retries for the subtasks in case of failure. The default is 0.

bool

Whether the subtasks are optional. If True, the subtasks will not fail the job if they fail. Tasks that depend on them will still execute even if they failed. The default is False.

Returns

A list of FutureTask objects representing the submitted subtasks. Can be used to set up dependencies between tasks.

# within the execute method of a Task:
subtasks = context.submit_subtasks([
    MySubtask(i) for i in range(10)
])
dependent_subtask = context.submit_subtask(
    MyOtherSubtask(), depends_on=subtasks
)

Context.submit_subtask ExecutionContext.runner_context

Python

Go

Context.submit_subtasks

Parameters

Returns

​Parameters

​Returns

Parameters

Returns