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