data class Connection(val id: String, val type: String?, val host: String?, val schema: String?, val login: String?, val password: String?, val port: Int?, val extra: Any?)

A connection registered in Airflow's connection store.

Context

data class Context(val dagRun: DagRun, val ti: TaskInstance)

Runtime context passed to the task execution.

CoordinatorServer

class CoordinatorServer(comm: InetSocketAddress, logs: InetSocketAddress) : Server

Serves task-execution requests over the coordinator's comm and logs sockets.

DagDef

class DagDef(val id: String)

A collection of tasks with directional dependencies.

DagRun

data class DagRun(val dagId: String, val runId: String, val logicalDate: OffsetDateTime?, val dataIntervalStart: OffsetDateTime?, val dataIntervalEnd: OffsetDateTime?, val runAfter: OffsetDateTime?, val runType: DagRunType?, val conf: Map<String, Any?>)

Identifies the Dag run that the current task instance belongs to.

DagRunType

enum DagRunType : Enum<DagRunType>

Deps

interface Deps

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

Endpoint

sealed interface Endpoint

One end of an ordering edge: a single task, or a whole task group.

InputTask

interface InputTask<I : TaskInput> : Task

A Task whose input the SDK resolves from the @task.stub TaskFlow call site in the Python Dag file and injects.

Label

class Label

The text of an edge label. The Airflow UI shows the label on the edge in the graph, as it does for Python's Label. The text comes before the task that the label is put on. That way the text sits between the two tasks of the edge in the code, just as the label sits between them in the graph:

MissingXComException

class MissingXComException(message: String) : IllegalStateException

Thrown when a task's input resolves to nothing where a value is required — a data parameter or a TaskInput field with a primitive type.

Server

sealed class Server

Connects this JVM process to the Airflow coordinator and dispatches task execution requests to the registered Bundle.

SwitchRef

class SwitchRef : Deps.Flow

A switch registered with a Dag: list the tasks it can choose between.

SwitchTask

interface SwitchTask : Task

A task that chooses one of several tasks to run; every other one is skipped.

Task

interface Task

A single unit of work executed by Airflow.

TaskDef

class TaskDef(val id: String, val definition: Class<out Task>) : Endpoint

One task definition: its ID, the class that implements it, its upstream dependencies, and its task-level configuration.

TaskGroupRef

class TaskGroupRef : Deps.Flow, Endpoint

A group of tasks in a Dag, shown in the Airflow UI as one node that expands: Python's TaskGroup.

TaskInput

interface TaskInput

Marks a class as a task's input: when the Python Dag file calls the stub task with keyword arguments, each public field receives the argument whose name matches it, ignoring case and underscores. That is the same fold the Go and TypeScript SDKs apply, so one Python signature binds identically in every SDK with nothing declared; ArgName pins a name the fold cannot reach.

TaskInstance

data class TaskInstance(val dagId: String, val runId: String, val taskId: String, val mapIndex: Int?, val tryNumber: Int)

Identifies the task instance that is currently executing.

TaskRef

class TaskRef<T> : Arg<T> , Deps.Flow

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

TaskStateStore

class TaskStateStore

Key-value state scoped to one task instance, shared across its retries within the same Dag run.

TriggerDagRun

class TriggerDagRun(val dagId: String)

A task that starts a run of another Dag, in place of a task class.