sdk/org.apache.airflow.sdk

Package-level declarations

Types

Thrown when an Airflow API call returns an error response.

Container for the annotation-based Dag-authoring API.

An immutable snapshot of all Dags that this JVM process can execute.

Entry point for declaring the Dags that this bundle contains.

Client for Airflow API calls scoped to the current task instance.

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.

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

Runtime context passed to the task execution.

class Dag(val id: String)

A collection of tasks with directional dependencies.

data class DagRun(val dagId: String, val runId: String)

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

class Server(comm: InetSocketAddress, logs: InetSocketAddress)

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

interface Task

A single unit of work executed by Airflow.

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.