From 9f446139be087bd077c4e8a15bd9f8c3d92762e5 Mon Sep 17 00:00:00 2001 From: j Date: Thu, 20 Feb 2025 10:15:35 -0500 Subject: [PATCH] log errors but don't fail --- app/item/tasks.py | 36 ++++++++++++++++++++++-------------- 1 file changed, 22 insertions(+), 14 deletions(-) diff --git a/app/item/tasks.py b/app/item/tasks.py index f51091a..fdd31f3 100644 --- a/app/item/tasks.py +++ b/app/item/tasks.py @@ -1,3 +1,4 @@ +import logging import os import tempfile @@ -12,6 +13,7 @@ from ..telegrambot import rpc as telegram_rpc from ..celery import app from . import models +logger = logging.getLogger(__name__) @app.task(queue="default", ignore_results=True) def announce_items(): @@ -32,21 +34,27 @@ def announce_items(): f.close() image = f.name if getattr(settings, "SIGNAL_ANNOUNCE_GROUP"): - r = rpc.send( - message, - group=settings.SIGNAL_ANNOUNCE_GROUP, - preview_url=link, - preview_title=item.title, - preview_image=image, - preview_description=description, - ) + try: + r = rpc.send( + message, + group=settings.SIGNAL_ANNOUNCE_GROUP, + preview_url=link, + preview_title=item.title, + preview_image=image, + preview_description=description, + ) + except: + logger.error("failed to send singal", exec_info=True) if getattr(settings, "TELEGRAM_ANNOUNCE_CHANNEL"): - message = f'{item.title}\n{link}' - r = telegram_rpc.send( - message, - channel=settings.TELEGRAM_ANNOUNCE_CHANNEL, - preview_image=image, - ) + try: + message = f'{item.title}\n{link}' + r = telegram_rpc.send( + message, + channel=settings.TELEGRAM_ANNOUNCE_CHANNEL, + preview_image=image, + ) + except: + logger.error("failed to send telegram", exec_info=True) item.save() if image: os.unlink(f.name)