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 bb8b526d2bc74f06f61a93cc2d0c3754344b4a1d Author: WenjinXie <[email protected]> AuthorDate: Sat Jan 17 19:17:32 2026 +0800 [runtime] Disable async exeuction for cross language resource. --- .../java/org/apache/flink/agents/plan/actions/ChatModelAction.java | 4 ++++ .../org/apache/flink/agents/plan/actions/ContextRetrievalAction.java | 5 +++++ 2 files changed, 9 insertions(+) diff --git a/plan/src/main/java/org/apache/flink/agents/plan/actions/ChatModelAction.java b/plan/src/main/java/org/apache/flink/agents/plan/actions/ChatModelAction.java index 9bde346a..ff5f6b9c 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/actions/ChatModelAction.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/actions/ChatModelAction.java @@ -26,6 +26,7 @@ import org.apache.flink.agents.api.agents.OutputSchema; import org.apache.flink.agents.api.chat.messages.ChatMessage; import org.apache.flink.agents.api.chat.messages.MessageRole; import org.apache.flink.agents.api.chat.model.BaseChatModelSetup; +import org.apache.flink.agents.api.chat.model.python.PythonChatModelSetup; import org.apache.flink.agents.api.context.DurableCallable; import org.apache.flink.agents.api.context.MemoryObject; import org.apache.flink.agents.api.context.RunnerContext; @@ -198,6 +199,9 @@ public class ChatModelAction { (BaseChatModelSetup) ctx.getResource(model, ResourceType.CHAT_MODEL); boolean chatAsync = ctx.getConfig().get(AgentExecutionOptions.CHAT_ASYNC); + // TODO: python chat model doesn't support async execution yet, see + // https://github.com/apache/flink-agents/issues/448 for details. + chatAsync = chatAsync && !(chatModel instanceof PythonChatModelSetup); Agent.ErrorHandlingStrategy strategy = ctx.getConfig().get(AgentExecutionOptions.ERROR_HANDLING_STRATEGY); diff --git a/plan/src/main/java/org/apache/flink/agents/plan/actions/ContextRetrievalAction.java b/plan/src/main/java/org/apache/flink/agents/plan/actions/ContextRetrievalAction.java index 72463010..1320c93c 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/actions/ContextRetrievalAction.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/actions/ContextRetrievalAction.java @@ -28,6 +28,7 @@ import org.apache.flink.agents.api.resource.ResourceType; import org.apache.flink.agents.api.vectorstores.BaseVectorStore; import org.apache.flink.agents.api.vectorstores.VectorStoreQuery; import org.apache.flink.agents.api.vectorstores.VectorStoreQueryResult; +import org.apache.flink.agents.api.vectorstores.python.PythonVectorStore; import org.apache.flink.agents.plan.JavaFunction; import java.util.List; @@ -59,6 +60,10 @@ public class ContextRetrievalAction { contextRetrievalRequestEvent.getVectorStore(), ResourceType.VECTOR_STORE); + // TODO: python vector store doesn't support async execution yet, see + // https://github.com/apache/flink-agents/issues/448 for details. + ragAsync = ragAsync && !(vectorStore instanceof PythonVectorStore); + final VectorStoreQuery vectorStoreQuery = new VectorStoreQuery( contextRetrievalRequestEvent.getQuery(),
