sdk/org.apache.airflow.sdk/Deps/TaskGroup

TaskGroup

One task group of the Dag being wired: a point in the flow, and the namespace of the tasks and groups declared inside it.

The generated wiring view nests one of these per Airflow.TaskGroup class, so a group is reached by calling it and its contents by calling on through:

staging().stage(rows);          // the task "staging.stage"
staging().checks().nulls(id);   // the task "staging.checks.nulls"
extract().before(staging());    // the whole group runs after extract

Functions

after

open fun after(vararg previous: Deps.Flow): Deps.Flow

Runs the tasks here after each of previous, carrying no value.

before

open fun before(vararg next: Deps.Flow): Deps.Flow

Runs the tasks here before each of next, carrying no value.

endpoints

open override fun endpoints(): List<Endpoint>

The ends an edge drawn here attaches to. A task stands for itself, so the default is nodes; a task group stands for the group rather than for the tasks it holds today.

groupId

abstract fun groupId(): String

Full ID of this group, as the Dag registered it.

nodes

open override fun nodes(): List<TaskDef>

The tasks at this point in the flow.