airflow.providers.standard.decorators.branch_python¶

函数¶

branch_task([python_callable, multiple_outputs])

将一个 Python 函数封装成 BranchPythonOperator。

airflow.providers.standard.decorators.branch_python.branch_task(python_callable=None, multiple_outputs=None, **kwargs)[源码]¶

将一个 Python 函数封装成 BranchPythonOperator。

有关如何使用此操作符的更多信息，请参阅指南：分支

接受操作符的关键字参数（kwargs）。可以在单个 DAG 中重用。

参数：

python_callable (Callable | None) – 要装饰的函数
multiple_outputs (bool | None) – 如果设置，函数的返回值将展开为多个 XCom 值。字典将展开为 XCom 值，其中键作为 XCom 键。默认为 False。