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。

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

接受操作符 kwarg 的 kwargs。可以在单个 DAG 中重复使用。

参数

  • python_callable (Callable | None) – 要装饰的函数

  • multiple_outputs (bool | None) – 如果设置，函数返回值将展开为多个 XCom 值。字典将展开为以键作为 XCom 键的 xcom 值。默认为 False。

此条目是否有帮助？