Context.submit_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]

Copy

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

Parameters

tasks Sequence[Task]

The tasks to submit as subtasks.

depends_on FutureTask | list[FutureTask] | None

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

cluster str

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

max_retries int

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

optional 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.

Request example

Python

# 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
)

Copy