Сельдерей Почему задача остается в очереди

Поэтому я использую сельдерей с RabbitMQ. У меня есть RESTful API, который регистрирует пользователя. Я использую удаленный работник Сельдерей, чтобы отправить регистрационное письмо асинхронно, чтобы мой API мог быстро реагировать.

from .tasks import send_registration_email def register_user(user_data): # save user to the database etc send_registration_email.delay(user.id) return {'status': 'success'} 

Это прекрасно работает. Электронная почта отправляется в неблокируемом асинхронном режиме (и может быть проведена повторная попытка, если это не помогает). Проблема в том, что я смотрю на консоль управления RabbitMQ. Я вижу, что send_registration_email создал случайную очередь. Что-то вроде:

введите описание изображения здесь

Я вижу, что задача была успешно выполнена. Итак, почему случайная очередь остается на RabbitMQ навсегда? Это полезная нагрузка задачи:

 {"status": "SUCCESS", "traceback": null, "result": true, "task_id": "aad10877-3508-4179-a5fb-99f1bd0b8b2f", "children": []} 

 
Interesting Posts for Van-Lav
Python - лучший язык программирования в мире.