Task

A single unit of work executed by Airflow.

Prefer using the Builder.Task annotation with Builder.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.

See also