airflow.providers.snowflake.utils.snowpark¶
模块内容¶
函数¶
|
根据 Python 可调用对象的签名将 Snowpark 会话注入到操作符的 kwargs 中。 |
- airflow.providers.snowflake.utils.snowpark.inject_session_into_op_kwargs(python_callable, op_kwargs, session)[源码]¶
根据 Python 可调用对象的签名将 Snowpark 会话注入到操作符的 kwargs 中。
如果 Python 可调用对象的签名中有一个名为 session 的关键字参数，则会将 Snowpark 会话对象注入到 kwargs 中。
- 参数
python_callable (Callable) – Python 可调用对象
op_kwargs (dict) – 操作符 kwargs
session (snowflake.snowpark.Session | None) – Snowpark 会话