airflow.decorators.python¶
模組內容¶
函式¶
|
將函式包裝成 Airflow 運算子。 |
- airflow.decorators.python.python_task(python_callable=None, multiple_outputs=None, **kwargs)[原始碼]¶
將函式包裝成 Airflow 運算子。
接受運算子 kwargs 的 kwargs。可在單一 DAG 中重複使用。
- 參數
python_callable (Callable | None) – 要裝飾的函式
multiple_outputs (bool | None) – 若設為 True，裝飾函式的回傳值將會展開為多個 XCom 值。Dict 將會展開為以其鍵作為 XCom 鍵的 XCom 值。預設為 False。