airflow.decorators.python

模块内容

函数

python_task([python_callable,  multiple_outputs])

将函数包装到 Airflow 操作符中。
airflow.decorators.python.python_task(python_callable=None, multiple_outputs=None, **kwargs)[源代码]

将函数包装到 Airflow 操作符中。

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

参数

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

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

此条目是否有帮助？