To submit subtasks from a task, you can use the submit_subtask method of the passed ExecutionContext object.

Returns a FutureTask object that represents the subtask that was submitted. This object can be used to specify dependencies between tasks.

Parameters

task
Task

The task to be submitted as a subtask.

depends_on
list[FutureTask]

An optional list of other tasks already submitted within the same context that this subtask depends on.

task
Task

An optional cluster slug to run the subtask on. If not provided, the subtask is run on the same cluster as the parent task.

task
Task

Specify the maximum number of retries for the subtask in case of failure. Defaults to 0.