Exception handling + Py3.12

pyproject.toml

@@ -6,7 +6,7 @@ authors = ["Amir Rachum <[email protected]>"]
 readme = "README.md"
 
 [tool.poetry.dependencies]
-python = "^3.11"
+python = "^3.12"
 todoist-api-python = "*"
 python-telegram-bot = {extras = ["job-queue", "callback-data"], version = "^20.1"}
 redis = "*"

src/spanreed/apis/obsidian.py

@@ -43,10 +43,13 @@ async def _send_request(
         self._logger.info(f"Sending request: {request=}")
 
         try:
-            await redis_api.lpush(
-                f"obsidian-plugin-tasks:{self._user.id}",
-                json.dumps(request),
-            )
+            async with asyncio.timeout(
+                datetime.timedelta(seconds=30).total_seconds()
+            ):
+                await redis_api.lpush(
+                    f"obsidian-plugin-tasks:{self._user.id}",
+                    json.dumps(request),
+                )
         except Exception:
             self._logger.error(f"Failed to send request: {request=}")
             raise

src/spanreed/plugins/habit_tracker.py

@@ -145,6 +145,9 @@ async def run_for_user(self, user: User) -> None:
                             config.habit_tracker_property_name,
                             habit.name,
                         )
+                        await bot.send_message(f"Awesome! Keep it up!")
+                    else:
+                        await bot.send_message("I'll ask again later")
 
             self._logger.info("Sleeping for 4 hours")
             await asyncio.sleep(datetime.timedelta(hours=4).total_seconds())
@@ -155,8 +158,6 @@ async def poll_user(self, habit: Habit, bot: TelegramBotApi) -> bool:
             prompt = f"Did you {habit.description} today?"
             if await bot.request_user_choice(prompt, ["Yes", "No"]) == 0:
                 self._logger.info(f"User said yes to {habit.name}")
-                await bot.send_message(f"Awesome! Keep it up!")
                 return True
             self._logger.info(f"User said no to {habit.name}")
-            await bot.send_message("I'll ask again later")
             return False

src/spanreed/plugins/spanreed_monitor.py

@@ -1,5 +1,6 @@
 import asyncio
 import traceback
+import logging
 
 import datetime
 from contextlib import suppress, asynccontextmanager
@@ -51,12 +52,16 @@ async def run_for_user(self, user: User) -> None:
 async def suppress_and_log_exception(
     *exceptions: type[Exception],
 ) -> AsyncGenerator[None, None]:
+    logger = logging.getLogger(__name__)
     try:
         yield
     except Exception as e:
         if not any(isinstance(e, exception) for exception in exceptions):
             raise
+        exception_str = "".join(
+            traceback.format_exception(type(e), e, None, limit=1)
+        )
+        logger.error(f"Suppressed exception: {exception_str}")
         await redis_api.lpush(
-            SpanreedMonitorPlugin.EXCEPTION_QUEUE_NAME,
-            "".join(traceback.format_exception(type(e), e, None)),
+            SpanreedMonitorPlugin.EXCEPTION_QUEUE_NAME, exception_str
         )