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[source]

提供 @task 語法的實作。

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]

動態取得供應商註冊的任務裝飾器，例如： @task.docker。

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

這個條目有幫助嗎？