From 3c122d6a8530610f8c031ee5ac94c2a3d3ad29b9 Mon Sep 17 00:00:00 2001 From: Amir Rachum Date: Tue, 10 Sep 2024 14:59:57 +0300 Subject: [PATCH] . --- src/spanreed/plugins/spanreed_monitor.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/spanreed/plugins/spanreed_monitor.py b/src/spanreed/plugins/spanreed_monitor.py index d737ee7..c6c8075 100644 --- a/src/spanreed/plugins/spanreed_monitor.py +++ b/src/spanreed/plugins/spanreed_monitor.py @@ -98,15 +98,21 @@ async def _monitor_obsidian_plugin(self, user: User) -> None: timeout -= time_since_last_watchdog with suppress(asyncio.TimeoutError): + self._logger.info(f"Waiting for event on {queue_name} with timeout {timeout}") async with asyncio.timeout(timeout.total_seconds()): _, event_json = await redis_api.blpop( queue_name, ) event = json.loads(event_json) - self._logger.info(f"Obsidian plugin event received: {event}") + self._logger.info( + f"Obsidian plugin event received: {event}" + ) if event["kind"] == "error": self._logger.info(f"Obsidian plugin error: {event}") - if event["message"] in self.OBSIDIAN_PLUGIN_ERROR_IGNORE_LIST: + if ( + event["message"] + in self.OBSIDIAN_PLUGIN_ERROR_IGNORE_LIST + ): continue time_since_last_obsidian_error_message = ( datetime.datetime.now()