From 413fdd21aa184566befe6b253445c86fbadf7c40 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: Fri, 9 Jan 2026 11:09:58 +0300 Subject: [PATCH] =?UTF-8?q?fix:=20=D0=B8=D1=81=D0=BF=D0=BE=D0=BB=D1=8C?= =?UTF-8?q?=D0=B7=D1=83=D0=B5=D0=BC=20transaction.on=5Fcommit=20=D0=B4?= =?UTF-8?q?=D0=BB=D1=8F=20Celery=20=D0=B7=D0=B0=D0=B4=D0=B0=D1=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Исправлена проблема race condition когда Celery задача process_message_notifications запускалась до завершения транзакции БД, что приводило к ошибке 'message_not_found'. Теперь задача запускается только после успешного commit, гарантируя что объект уже доступен в базе данных для worker процесса. --- .../communications/notification_signals.py | 30 ++++++++++--------- 1 file changed, 16 insertions(+), 14 deletions(-) diff --git a/backend/communications/notification_signals.py b/backend/communications/notification_signals.py index d5bfbdea..74ceadcc 100644 --- a/backend/communications/notification_signals.py +++ b/backend/communications/notification_signals.py @@ -9,6 +9,7 @@ Signals для автоматической генерации уведомле """ import re +from django.db import transaction from django.db.models.signals import post_save, m2m_changed from django.dispatch import receiver from django.contrib.auth import get_user_model @@ -88,20 +89,21 @@ def create_message_notifications(sender, instance, created, **kwargs): # Signal handler сразу возвращает управление from notifications.tasks import process_message_notifications_task - try: - # Запускаем асинхронно через 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 - logger = logging.getLogger(__name__) - logger.error(f"Failed to queue message notifications: {e}", exc_info=True) + def send_task(): + """Отложенная отправка задачи после commit транзакции""" + try: + # Запускаем асинхронно через 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) + + # ВАЖНО: Запускаем задачу только после commit транзакции + # Иначе Celery worker не найдет объект в БД (race condition) + transaction.on_commit(send_task) def _create_message_notifications_sync(instance):