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 工作階段