From 9e495a1c23294e2852cf626241a6f3002e2e607d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=98=D0=B3=D0=BE=D1=80=D1=8C=20=D0=9D=D0=B0=D0=B4=D0=B5?= =?UTF-8?q?=D0=B8=D0=BD?= Date: Thu, 8 Jan 2026 17:07:27 +0300 Subject: [PATCH] =?UTF-8?q?=D0=A3=D0=B1=D1=80=D0=B0=D0=BD=D0=B0=20=D0=BF?= =?UTF-8?q?=D1=80=D0=BE=D0=B2=D0=B5=D1=80=D0=BA=D0=B0=20is=5Fcelery=5Favai?= =?UTF-8?q?lable()=20-=20=D0=B2=D1=81=D0=B5=D0=B3=D0=B4=D0=B0=20=D0=BF?= =?UTF-8?q?=D1=8B=D1=82=D0=B0=D0=B5=D0=BC=D1=81=D1=8F=20=D0=B8=D1=81=D0=BF?= =?UTF-8?q?=D0=BE=D0=BB=D1=8C=D0=B7=D0=BE=D0=B2=D0=B0=D1=82=D1=8C=20Celery?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/communications/notification_signals.py | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/backend/communications/notification_signals.py b/backend/communications/notification_signals.py index cd9a41b0..66299010 100644 --- a/backend/communications/notification_signals.py +++ b/backend/communications/notification_signals.py @@ -86,15 +86,16 @@ def create_message_notifications(sender, instance, created, **kwargs): # Запускаем ВСЮ обработку асинхронно в одной задаче # Signal handler сразу возвращает управление from notifications.tasks import process_message_notifications_task - from notifications.services import is_celery_available try: - if is_celery_available(): - # Запускаем асинхронно - НЕ БЛОКИРУЕМ - process_message_notifications_task.delay(instance.id) - else: - # Fallback: выполняем синхронно (только для разработки) - _create_message_notifications_sync(instance) + # Запускаем асинхронно через Celery + process_message_notifications_task.delay(instance.id) + except Exception as e: + # Если Celery недоступен - fallback на синхронную обработку + import logging + logger = logging.getLogger(__name__) + logger.warning(f"Celery unavailable, using sync fallback: {e}") + _create_message_notifications_sync(instance) except Exception as e: # Если что-то пошло не так, логируем но не ломаем сохранение сообщения import logging