airflow.decorators

Package Contents

Classes

TaskDecorator

Type declaration for task_decorator_factory return type.

TaskDecoratorCollection

Implementation to provide the @task syntax.

Functions

bash_task([python_callable])

Wrap a function into a BashOperator.

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]
bash[source]
run_if[source]
skip_if[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?