From 5b1298924efa6bef311c36c36cf9c574202ffaf5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E0=AE=AE=E0=AE=A9=E0=AF=8B=E0=AE=9C=E0=AF=8D=E0=AE=95?= =?UTF-8?q?=E0=AF=81=E0=AE=AE=E0=AE=BE=E0=AE=B0=E0=AF=8D=20=E0=AE=AA?= =?UTF-8?q?=E0=AE=B4=E0=AE=A9=E0=AE=BF=E0=AE=9A=E0=AF=8D=E0=AE=9A=E0=AE=BE?= =?UTF-8?q?=E0=AE=AE=E0=AE=BF?= Date: Mon, 2 Sep 2024 07:36:05 +0530 Subject: [PATCH] log --- openhands/events/stream.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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):