Skip to main content
def ExecutionContext.submit_subtask(
  task: Task,
  depends_on: list[FutureTask] = None,
  cluster: str | None = None,
  max_retries: int = 0,
  optional: bool = False
) -> FutureTask
Submit a subtask from a currently executing task.

​
Parameters

​
task
Task
The task to submit as a subtask.
​
depends_on
list[FutureTask]
An optional list of tasks already submitted within the same context that this subtask depends on.
​
cluster
str
An optional cluster slug for running the subtask. If not provided, the subtask runs on the same cluster as the parent task.
​
max_retries
int
Specify the maximum number of retries for the subtask in case of failure. The default is 0.
​
optional
bool
Whether the subtask is optional. If True, the subtask will not fail the job if it fails. Tasks that depend on this task will still execute even if this task failed. The default is False.

​
Returns

A FutureTask object that represents the submitted subtask. Can be used to set up dependencies between tasks. 
# within the execute method of a Task:
subtask = context.submit_subtask(MySubtask())
dependent_subtask = context.submit_subtask(
    MyOtherSubtask(), depends_on=[subtask]
)
gpu_task = context.submit_subtask(
    MyGPUTask(),
    cluster="gpu-cluster-slug"
)
flaky_task = context.submit_subtask(
    MyFlakyTask(),
    max_retries=5
)
optional_task = context.submit_subtask(
    MyOptionalTask(),
    optional=True
)