From cc2f96c6c4833629d4c11a29c34d8b9bbb6e4b36 Mon Sep 17 00:00:00 2001 From: Xingyao Wang Date: Thu, 19 Jun 2025 11:57:44 -0400 Subject: [PATCH] Fix search_events signature mismatches after get_events replacement (#9238) Co-authored-by: openhands --- openhands/server/routes/feedback.py | 5 ++++- openhands/server/routes/trajectory.py | 3 ++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/openhands/server/routes/feedback.py b/openhands/server/routes/feedback.py index b376235e2e..2adc1855e2 100644 --- a/openhands/server/routes/feedback.py +++ b/openhands/server/routes/feedback.py @@ -3,6 +3,7 @@ from fastapi.responses import JSONResponse from openhands.core.logger import openhands_logger as logger from openhands.events.async_event_store_wrapper import AsyncEventStoreWrapper +from openhands.events.event_filter import EventFilter from openhands.events.serialization import event_to_dict from openhands.server.data_models.feedback import FeedbackDataModel, store_feedback from openhands.server.dependencies import get_dependencies @@ -41,7 +42,9 @@ async def submit_feedback( # Assuming the storage service is already configured in the backend # and there is a function to handle the storage. body = await request.json() - async_store = AsyncEventStoreWrapper(conversation.event_stream, filter_hidden=True) + async_store = AsyncEventStoreWrapper( + conversation.event_stream, filter=EventFilter(exclude_hidden=True) + ) trajectory = [] async for event in async_store: trajectory.append(event_to_dict(event)) diff --git a/openhands/server/routes/trajectory.py b/openhands/server/routes/trajectory.py index c812feb988..5f33e4c064 100644 --- a/openhands/server/routes/trajectory.py +++ b/openhands/server/routes/trajectory.py @@ -3,6 +3,7 @@ from fastapi.responses import JSONResponse from openhands.core.logger import openhands_logger as logger from openhands.events.async_event_store_wrapper import AsyncEventStoreWrapper +from openhands.events.event_filter import EventFilter from openhands.events.serialization import event_to_trajectory from openhands.server.dependencies import get_dependencies from openhands.server.session.conversation import ServerConversation @@ -30,7 +31,7 @@ async def get_trajectory( """ try: async_store = AsyncEventStoreWrapper( - conversation.event_stream, filter_hidden=True + conversation.event_stream, filter=EventFilter(exclude_hidden=True) ) trajectory = [] async for event in async_store: