[ci] Fix test failures due to event refactor.

Author: wenjin272

python/flink_agents/e2e_tests/e2e_tests_integration/agent_skills_test.py

@@ -111,8 +111,8 @@ def system_prompt() -> Prompt:
     @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",

python/flink_agents/e2e_tests/e2e_tests_integration/long_term_memory_test.py

@@ -119,7 +119,7 @@ def __init__(self, value: Any) -> None:
     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: