This is an automated email from the ASF dual-hosted git repository.
wenjin272 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
The following commit(s) were added to refs/heads/main by this push:
new 388a89e4 [bugfix][docs] Fix workflow agent quickstart code snippet and
comment (#808)
388a89e4 is described below
commit 388a89e416c06d23b269d958bd1c66ea47633843
Author: Haocong Wang <[email protected]>
AuthorDate: Mon Jun 8 19:22:48 2026 +0800
[bugfix][docs] Fix workflow agent quickstart code snippet and comment (#808)
Co-authored-by: Claude Opus 4.6 (1M context) <[email protected]>
---
docs/content/docs/get-started/quickstart/workflow_agent.md | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/docs/content/docs/get-started/quickstart/workflow_agent.md
b/docs/content/docs/get-started/quickstart/workflow_agent.md
index cc2520f1..6feeb65c 100644
--- a/docs/content/docs/get-started/quickstart/workflow_agent.md
+++ b/docs/content/docs/get-started/quickstart/workflow_agent.md
@@ -132,8 +132,7 @@ class ReviewAnalysisAgent(Agent):
@staticmethod
def process_input(event: Event, ctx: RunnerContext) -> None:
"""Process input event and send chat request for review analysis."""
- input_event = InputEvent.from_event(event)
- input: ProductReview = input_event.input
+ input =
ProductReview.model_validate(InputEvent.from_event(event).input)
ctx.short_term_memory.set("id", input.id)
content = f"""
