Skip to content

Commit cf50e0e

Browse files
committed
Make dispatch receiving less chatty/verbose
Signed-off-by: Mathias L. Baumann <[email protected]>
1 parent a93e667 commit cf50e0e

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/frequenz/dispatch/_bg_service.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -259,16 +259,18 @@ async def _fetch(self) -> None:
259259
self._dispatches[dispatch.id] = Dispatch(client_dispatch)
260260
old_dispatch = old_dispatches.pop(dispatch.id, None)
261261
if not old_dispatch:
262-
_logger.info("New dispatch: %s", dispatch)
262+
_logger.debug("New dispatch: %s", dispatch)
263263
await self._update_dispatch_schedule_and_notify(dispatch, None)
264264
await self._lifecycle_events_tx.send(Created(dispatch=dispatch))
265265
elif dispatch.update_time != old_dispatch.update_time:
266-
_logger.info("Updated dispatch: %s", dispatch)
266+
_logger.debug("Updated dispatch: %s", dispatch)
267267
await self._update_dispatch_schedule_and_notify(
268268
dispatch, old_dispatch
269269
)
270270
await self._lifecycle_events_tx.send(Updated(dispatch=dispatch))
271271

272+
_logger.info("Received %s dispatches", len(self._dispatches))
273+
272274
except grpc.aio.AioRpcError as error:
273275
_logger.error("Error fetching dispatches: %s", error)
274276
self._dispatches = old_dispatches

0 commit comments

Comments
 (0)