Как решить исключение 'Not Registered' для сельдерея
dev env django = 3.2.4 celery = 5.2.3 redis
Я использую Celery для асинхронной обработки. Я использую его для передачи электронной почты и функции AI Inference, но @sharedtask, примененная к электронной почте, работает без проблем. Однако функция AI Inference работает по-другому. После успешного завершения и последующего выполнения того же действия отображается исключение "Не зарегистрировано". Почему это происходит? Успех и неудача одной и той же задачи показаны ниже
введите описание изображения здесь
Я предполагаю, что ваш работник не знаком с call_ai_engine_api_task.
Есть несколько способов сделать это, например:
app = Celery("my_app", broker=..., backend=..., include=["path.to.call_ai_engine_api_task", ..])
или с помощью этой техники.
Затем вы можете увидеть список зарегистрированных заданий в журналах запуска рабочих.