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 77a2ca4d [ci] Fix test failures due to event refactor.
77a2ca4d is described below
commit 77a2ca4d200ebc95ffd1af681e674301dd49c71b
Author: WenjinXie <[email protected]>
AuthorDate: Thu May 7 19:58:08 2026 +0800
[ci] Fix test failures due to event refactor.
---
.../flink_agents/e2e_tests/e2e_tests_integration/agent_skills_test.py | 4 ++--
.../e2e_tests/e2e_tests_integration/long_term_memory_test.py | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/python/flink_agents/e2e_tests/e2e_tests_integration/agent_skills_test.py
b/python/flink_agents/e2e_tests/e2e_tests_integration/agent_skills_test.py
index 6f824f76..8e5d13f8 100644
--- a/python/flink_agents/e2e_tests/e2e_tests_integration/agent_skills_test.py
+++ b/python/flink_agents/e2e_tests/e2e_tests_integration/agent_skills_test.py
@@ -111,8 +111,8 @@ class SkillTestAgent(Agent):
@staticmethod
def process_input(event: Event, ctx: RunnerContext) -> None:
input_event = InputEvent.from_event(event)
- if isinstance(input_event.input, Operation):
- input: Operation = input_event.input
+ if isinstance(input_event.input, dict):
+ input: Operation = Operation(**input_event.input)
ctx.send_event(
ChatRequestEvent(
model="openai_setup",
diff --git
a/python/flink_agents/e2e_tests/e2e_tests_integration/long_term_memory_test.py
b/python/flink_agents/e2e_tests/e2e_tests_integration/long_term_memory_test.py
index 857979ab..a5dc3283 100644
---
a/python/flink_agents/e2e_tests/e2e_tests_integration/long_term_memory_test.py
+++
b/python/flink_agents/e2e_tests/e2e_tests_integration/long_term_memory_test.py
@@ -119,7 +119,7 @@ class MyEvent(Event):
def from_event(cls, event: Event) -> "MyEvent":
"""Reconstruct a MyEvent from a generic Event."""
assert "value" in event.attributes
- return MyEvent(value=event.attributes["value"])
+ return MyEvent(value=Record.model_validate(event.attributes["value"]))
@property
def value(self) -> Any:
