airflow.decorators

包内容

类

TaskDecorator

task_decorator_factory 返回类型的类型声明。

TaskDecoratorCollection

提供 @task 语法的实现。

函数

bash_task([python_callable])

将一个函数包装成一个 BashOperator。

branch_external_python_task([python_callable, ...])

将一个 Python 函数包装成一个 BranchExternalPythonOperator。

branch_task([python_callable, multiple_outputs])

将一个 Python 函数包装成一个 BranchPythonOperator。

branch_virtualenv_task([python_callable, multiple_outputs])

将一个 Python 函数包装成一个 BranchPythonVirtualenvOperator。

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

将一个可调用对象包装成一个 Airflow 操作符，以便通过 Python 虚拟环境运行。

python_task([python_callable, multiple_outputs])

将一个函数包装成一个 Airflow 操作符。

virtualenv_task([python_callable, multiple_outputs])

将一个可调用对象包装成一个 Airflow 操作符，以便通过 Python 虚拟环境运行。

sensor_task([python_callable])

将一个函数包装成一个 Airflow 操作符。

short_circuit_task([python_callable, multiple_outputs])

将一个函数包装成一个 ShortCircuitOperator。

task_group

实现 @task_group 函数装饰器。

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

Python DAG 装饰器，将一个函数包装成一个 Airflow DAG。

属性

task

setup

teardown

class airflow.decorators.TaskDecoratorCollection[源代码]

提供 @task 语法的实现。

python[源代码]
virtualenv[源代码]
external_python[源代码]
branch[源代码]
branch_virtualenv[源代码]
branch_external_python[源代码]
short_circuit[源代码]
sensor[源代码]
bash[源代码]
run_if[源代码]
skip_if[源代码]
__call__: Any[源代码]
__getattr__(name)[源代码]

动态获取提供程序注册的任务装饰器，例如 @task.docker。

airflow.decorators.task[源代码]
airflow.decorators.setup: Callable[源代码]
airflow.decorators.teardown: Callable[源代码]

此条目是否有帮助？