Django celery не обрабатывает фоновую задачу?

Question

[s7fkcu]

Всем привет. Есть проект на django 2.2 и celery 4.2.2
После регистрации в фоновом режиме отправляю письмо на активацию аккаунта. Celery видеть таск, пишет "received task", но саму функцию не исполняет.

# view
class SignUpFormView(FormView):
    .....
    def form_valid(self, form):

        current_site = get_current_site(self.request)
        mail_subject = 'Активация аккаунта '
        to_email = [
            form.cleaned_data.get('email'),
        ]
        from_email = settings.EMAIL_HOST_USER
        ctx = {
            'user': user,
            'domain': current_site,
            'uid': urlsafe_base64_encode(force_bytes(user.pk)),
            'token': account_activation_token.make_token(user),
        }
        message = render_to_string('mail/acc_active_email.html', ctx)
        send_mail_activation.delay(message, mail_subject, from_email, to_email)
        return super(SignUpFormView, self).form_valid(form)

# task
@task()
def send_mail_activation(message, mail_subject, from_email, to_email):
    msg = EmailMessage(mail_subject, message, from_email, to_email)
    msg.content_subtype = 'html'
    msg.send()

настройки сельдерея

# settings.py
CELERY_BROKER_URL = 'redis://127.0.0.1:6379/1'

# celery.py
import os
from celery import Celery
from django.conf import settings
# Основыне настройки Django для celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings.settings')
# for Windows
os.environ.setdefault('FORKED_BY_MULTIPROCESSING', '1')
app = Celery('settings')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

# __init__.py
from .celery import app as celery_app
__all__ = ('celery_app',)

в чем может быть проблема ?

Comments

[FulTupFul]

Может с настройками эмайл бекенда что-то не так?
Проверьте функцию в обычном режиме. Попробуйте посмотреть статус задачи через

task = send_mail_activation.delay(message, mail_subject, from_email, to_email)
task.status

[s7fkcu]

FulTupFul, Если отправляю эмайл без фоновой обработки, все работает, т.е. бекенд настроен. Самое интересно то, что такой же код использовал в другом проекте и он работает, но была Django 2.0.8.
Я откатил версию, все равно не работает.
Кстати разработку виду на windows, попробую сейчас на linux - мб дело в этом.

[s7fkcu]

FulTupFul, сделал простую функцию

@task()
def test():
    print(1)

# shell
result = test.delay()
result.status

Выдает: 'DisabledBackend' object has no attribute '_get_task_meta_for'
при том, что

# settings.py
CELERY_BROKER_URL = 'redis://127.0.0.1:6379/1'
CELERY_RESULTS_BACKEND = 'redis://127.0.0.1:6379/1'

[FulTupFul]

Итак. Адрес брокера и результирующего бэкенда не попадают в настройки celery app
на этой строчке - app = Celery('settings')
Из-за того что вы указали названия приложения как settings.settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings.settings') 
# Вместо settings надо указать имя вашего корневого приложения например my_app.settings

Лучше всего будет передать адрес брокера напрямую в app:

app = Celery('records', broker='redis://localhost:6379/1',
             backend='redis://localhost:6379/1')

Постарайтесь недопустить коллизий между вашими приложениями. Используйте разные адреса redis://localhost:6379/1, redis://localhost:6379/2 и.т.д.
Скачайте какой-нибудь десктоп менеджер для мониторинга выполнения задач, например Redis Desktop Manager. Такие задачи очень легко дебажатся

[s7fkcu]

FulTupFul, так у меня "корневая" папка приложения называется "settings", мне его переименовать ?
а почему раньше работало ?
и да сейчас поставил настройки брокера напрямую, выдает такую ошибку

from . import async, base
                      ^
SyntaxError: invalid syntax
# в файле "d:\development\django\parlamar.ru\env\lib\site-packages\celery\backends\redis.py" ругается на импорт
from . import async, base

[FulTupFul]

s7fkcu, в python3.7 слово async было зарезервировано, нужно заменить все слова async. Или скачать библиотеку напрямую из github
Название корневого приложения менять не надо, но это очень странное название

[s7fkcu]

FulTupFul, Решил проблему, у меня стоял python 3.7, что выдает с celery 4.2.2 ошибку импорта.
откатил до версии 3.6.8 - и все заработало!
Спасибо, за помощь!