diff --git a/openhands/events/stream.py b/openhands/events/stream.py index 7dfe64988ec7..5955c506e263 100644 --- a/openhands/events/stream.py +++ b/openhands/events/stream.py @@ -131,11 +131,12 @@ def get_latest_event_id(self) -> int: def subscribe(self, id: EventStreamSubscriber, callback: Callable, append=False): if id in self._subscribers: if append: - logger.info(f'Appending callback to subscriber {id}') + logger.debug(f'Appending callback to subscriber {id}') self._subscribers[id].append(callback) else: raise ValueError('Subscriber already exists: ' + id) else: + logger.debug(f'Subscribing to {id}') self._subscribers[id] = [callback] def unsubscribe(self, id: EventStreamSubscriber):