sdk/org.apache.airflow.sdk/TaskRef

TaskRef

The output of a registered task, and the task's place in the flow.

Passing this handle into another task's arguments feeds this task's return value into that parameter and wires the data edge. Deps.Flow.before and Deps.Flow.after wire an ordering-only edge instead, where nothing flows but the sequence.

Type Parameters

Return type of the task this handle refers to.

Functions

after

open override fun after(vararg previous: Deps.Flow): TaskRef<T>

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

before

open override fun before(vararg next: Deps.Flow): TaskRef<T>

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

config

fun config(key: String, value: Any?): TaskRef<T>

Sets one task-level configuration value, so a task built through DagDef.task is configured where it is created.

endpoints

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

nodes

open override fun nodes(): List<TaskDef>

The tasks at this point in the flow.