Django celery + транспорт Redis - бесконечный цикл, по умолчанию работает debug_task

Не могу обнаружить ошибку. Django 2.2, celery 5.2.1, название проекта = sharp. Также пробовал декоратор shared_task вместо app.task, та же ситуация. Default debug_task (см. ниже) работает нормально. Мой celery.py:

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'sharp.settings')
app = Celery('sharp')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
@app.task(bind=True)
def debug_task(self):
    print(f'Request: {self.request!r}')

__init__.py такой же, как на официальной странице celery. Настройки:

CELERY_BROKER_URL = 'redis://default:xxx@172.31.34.124:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Europe/Paris'

Моя задача:

from sharp.celery import app

@app.task(name='sendit')
def _send_email_messages(recipient_email, messages, from_email, attachments):
    print('x') # not important stuff, just to have something here

За бесконечным циклом следует мой вывод:

Пожалуйста, игнорируйте эту штуку DEBUG, она не работает даже в продакшене. Отчаиваюсь, вы видите что-нибудь неправильное с этой установкой?

Вернуться на верх