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 87d6791852d14598459ea096afc78e62b80eda9a Author: WenjinXie <[email protected]> AuthorDate: Sun Sep 28 14:14:14 2025 +0800 [hotfix] Fix react agent quickstart example doc strings. --- python/flink_agents/examples/quickstart/react_agent_example.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/python/flink_agents/examples/quickstart/react_agent_example.py b/python/flink_agents/examples/quickstart/react_agent_example.py index 2d54603..eb638e9 100644 --- a/python/flink_agents/examples/quickstart/react_agent_example.py +++ b/python/flink_agents/examples/quickstart/react_agent_example.py @@ -53,7 +53,7 @@ def main() -> None: env = StreamExecutionEnvironment.get_execution_environment() agents_env = AgentsExecutionEnvironment.get_execution_environment(env) - # Add Ollama chat model connection and record shipping question tool to be used + # Add Ollama chat model connection and notify shipping manager tool to be used # by the Agent. agents_env.add_resource( "ollama_server", @@ -91,8 +91,8 @@ def main() -> None: output_schema=ProductReviewAnalysisRes, ) - # Use the ReAct agent to analyze each product review and - # record shipping question. + # Use the ReAct agent to analyze each product review and notify the shipping manager + # when needed. review_analysis_res_stream = ( agents_env.from_datastream( input=product_review_stream, key_selector=lambda x: x.id
