This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-agents.git
commit afc0e6a68a50a5fb5ee92c9b84080ad29e90d431 Author: youjin <[email protected]> AuthorDate: Tue Jan 13 18:56:16 2026 +0800 [hotfix] Bypass Pydantic validation for Java resource wrappers --- python/flink_agents/runtime/java/java_chat_model.py | 5 ++++- python/flink_agents/runtime/java/java_embedding_model.py | 6 +++++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/python/flink_agents/runtime/java/java_chat_model.py b/python/flink_agents/runtime/java/java_chat_model.py index f4501e8..1d43224 100644 --- a/python/flink_agents/runtime/java/java_chat_model.py +++ b/python/flink_agents/runtime/java/java_chat_model.py @@ -102,7 +102,10 @@ class JavaChatModelSetupImpl(JavaChatModelSetup): j_resource_adapter: The Java resource adapter for method invocation **kwargs: Additional keyword arguments """ - super().__init__(**kwargs) + # connection is a required parameter for BaseChatModelSetup + connection = kwargs.pop("connection", "") + super().__init__(connection = connection, **kwargs) + self._j_resource=j_resource self._j_resource_adapter=j_resource_adapter diff --git a/python/flink_agents/runtime/java/java_embedding_model.py b/python/flink_agents/runtime/java/java_embedding_model.py index 7cfe93d..c53a2a8 100644 --- a/python/flink_agents/runtime/java/java_embedding_model.py +++ b/python/flink_agents/runtime/java/java_embedding_model.py @@ -79,7 +79,11 @@ class JavaEmbeddingModelSetupImpl(JavaEmbeddingModelSetup): j_resource_adapter: The Java resource adapter for method invocation **kwargs: Additional keyword arguments """ - super().__init__(**kwargs) + # connection,model are required parameters for BaseEmbeddingModelSetup + connection = kwargs.pop("connection", "") + model = kwargs.pop("model", "") + super().__init__(connection = connection, model = model, **kwargs) + self._j_resource=j_resource self._j_resource_adapter=j_resource_adapter
