Task

A single unit of work executed by Airflow.

Prefer using the Airflow.Task annotation with Airflow.Dag to have the annotation processor generate an implementation for you. Only use this interface if you need to do low-level plumbing.

Implement this interface to define task logic. Airflow instantiates the class via its no-argument constructor, then calls execute once per task-instance run.

Implement InputTask instead for a task the Python Dag file calls with TaskFlow arguments; the SDK then resolves those arguments and injects them.

See also

Inheritors