From d03efa284aa3c5d16fda9e9cfac6b3adc385a645 Mon Sep 17 00:00:00 2001 From: tofarr Date: Mon, 2 Jun 2025 14:15:41 -0600 Subject: [PATCH] Added X-Session-API-Key to nested event store (#8857) --- openhands/events/nested_event_store.py | 6 +++++- .../docker_nested_conversation_manager.py | 4 +++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/openhands/events/nested_event_store.py b/openhands/events/nested_event_store.py index 81ee382462..07b42ab918 100644 --- a/openhands/events/nested_event_store.py +++ b/openhands/events/nested_event_store.py @@ -19,6 +19,7 @@ class NestedEventStore(EventStoreABC): base_url: str sid: str user_id: str | None + session_api_key: str | None = None def search_events( self, @@ -37,7 +38,10 @@ class NestedEventStore(EventStoreABC): search_params['limit'] = min(100, limit) search_str = urlencode(search_params) url = f'{self.base_url}/events{search_str}' - response = httpx.get(url) + headers = {} + if self.session_api_key: + headers['X-Session-API-Key'] = self.session_api_key + response = httpx.get(url, headers=headers) result_set = response.json() for result in result_set['results']: event = event_from_dict(result) diff --git a/openhands/server/conversation_manager/docker_nested_conversation_manager.py b/openhands/server/conversation_manager/docker_nested_conversation_manager.py index 2abd381667..cac91fdef3 100644 --- a/openhands/server/conversation_manager/docker_nested_conversation_manager.py +++ b/openhands/server/conversation_manager/docker_nested_conversation_manager.py @@ -124,14 +124,16 @@ class DockerNestedConversationManager(ConversationManager): ) nested_url = self._get_nested_url(sid) + session_api_key = self._get_session_api_key_for_conversation(sid) return AgentLoopInfo( conversation_id=sid, url=nested_url, - session_api_key=self._get_session_api_key_for_conversation(sid), + session_api_key=session_api_key, event_store=NestedEventStore( base_url=nested_url, sid=sid, user_id=user_id, + session_api_key=session_api_key, ), status=ConversationStatus.STARTING if sid in self._starting_conversation_ids