airflow.decorators¶

Package Contents¶

Classes¶

TaskDecorator

Type declaration for task_decorator_factory return type.

TaskDecoratorCollection

Implementation to provide the @task syntax.

Functions¶

branch_external_python_task([python_callable, ...])

Wrap a python function into a BranchExternalPythonOperator.

branch_task([python_callable, multiple_outputs])

Wrap a python function into a BranchPythonOperator.

branch_virtualenv_task([python_callable, multiple_outputs])

Wrap a python function into a BranchPythonVirtualenvOperator.

external_python_task([python, python_callable, ...])

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

python_task([python_callable, multiple_outputs])

Wrap a function into an Airflow operator.

virtualenv_task([python_callable, multiple_outputs])

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

sensor_task([python_callable])

Wrap a function into an Airflow operator.

short_circuit_task([python_callable, multiple_outputs])

Wrap a function into an ShortCircuitOperator.

task_group

Implements the @task_group function decorator.

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

Python dag decorator which wraps a function into an Airflow DAG.

Attributes¶

task

setup

teardown

class airflow.decorators.TaskDecoratorCollection[source]¶

Implementation to provide the @task syntax.

python[source]¶
virtualenv[source]¶
external_python[source]¶
branch[source]¶
branch_virtualenv[source]¶
branch_external_python[source]¶
short_circuit[source]¶
sensor[source]¶
__call__: Any[source]¶
__getattr__(name)[source]¶

Dynamically get provider-registered task decorators, e.g. @task.docker.

airflow.decorators.task[source]¶
airflow.decorators.setup: Callable[source]¶
airflow.decorators.teardown: Callable[source]¶

Was this entry helpful?