`airflow.decorators.branch_python`¶

模組內容¶

branch_task([python_callable, multiple_outputs])

將 Python 函數包裝成 BranchPythonOperator。

airflow.decorators.branch_python.branch_task(python_callable=None, multiple_outputs=None, **kwargs)[原始碼]¶

將 Python 函數包裝成 BranchPythonOperator。

如需更多關於如何使用此運算子的資訊，請查看指南：分支

接受運算子 kwargs 的 kwargs。可以在單一 DAG 中重複使用。

參數

python_callable (Callable | None) – 要裝飾的函數
multiple_outputs (bool | None) – 如果設定，函數傳回值將展開為多個 XCom 值。Dict 將展開為以鍵作為 XCom 鍵的 xcom 值。預設為 False。