TaskDecorator

Type declaration for task_decorator_factory return type.

TaskDecoratorCollection

Implementation to provide the @task syntax.

branch_task([python_callable, multiple_outputs])

Wraps a python function into a BranchPythonOperator.

external_python_task([python, python_callable, …])

Wraps a callable into an Airflow operator to run via a Python virtual environment.

python_task([python_callable, multiple_outputs])

Wraps a function into an Airflow operator.

virtualenv_task([python_callable, multiple_outputs])

Wraps a callable into an Airflow operator to run via a Python virtual environment.

sensor_task([python_callable])

Wraps a function into an Airflow operator.

short_circuit_task([python_callable, multiple_outputs])

Wraps a function into an ShortCircuitOperator.

task_group

Implements the @task_group function decorator.

dag([dag_id, description, schedule, …])

Python dag decorator. Wraps a function into an Airflow DAG.

task

setup

teardown