Deps

interface Deps

Vocabulary for declaring a Dag's task graph in Java, and the base of every generated <Dag>Deps wiring view.

An Airflow.Deps class inherits lit and Flow by simple name, so it needs no import and Flow does not collide with java.util.concurrent.Flow. Label is not inherited, so the class has to import it.

Types

Flow

interface Flow

A point in the task graph: one task, one task group, or a set of them.

TaskGroup

interface TaskGroup : Deps.Flow

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

Functions

lit

open fun <T> lit(value: T?): Arg<T>

Wraps an inline constant as a task argument, as in transform(extract(), lit(0.9)). It is passed to the task as a constant and creates no dependency edge.