airflow.providers.standard.decorators.python

函数

python_task([python_callable, multiple_outputs])

将函数包装成 Airflow 操作器。

模块内容

airflow.providers.standard.decorators.python.python_task(python_callable=None, multiple_outputs=None, **kwargs)[源代码]

将函数包装成 Airflow 操作器。

接受操作器关键字参数 (kwargs)。可以在单个 DAG 中重用。

参数:

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

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

此条目有帮助吗？