sdk/org.apache.airflow.sdk/Bundle

Bundle

All DagDefs that this JVM process can execute.

Register everything before passing the bundle to Server.serve: serving ends registration, so a register left below it fails rather than racing the running task.

Throws

IllegalArgumentException

if any two Dags share the same ID, if a task depends on an upstream that is not registered in its own Dag, or if the dependencies of a Dag contain a cycle.

Constructors

Bundle

constructor(dags: Iterable<DagDef>)

constructor()

Creates an empty bundle to register into.

Functions

fun register(annotated: Class<*>): Bundle

Registers what an annotated class holds, read from the class itself so there is no second name to keep in sync.

fun register(dag: DagDef): Bundle

Registers a Dag.

fun register(dagId: String, taskId: String, definition: Class<out Task>): Bundle

Registers one task implementation against a Dag the Python file owns, for a task with no annotation to read the ids from.