Я предполагаю, что вы используете декоратор shared_task и запускаете задачи как function_name.delay ()
Это можно проверить, добавив условие, которое запускает задачу, если она выполняется локально (или с помощью теста)и использует сельдерей в производстве.Это также позволяет запускать сервер локально, без использования сельдерея, и это может быть проще для отладки и обслуживания.
PRODUCTION = False
if PRODUCTION:
some_task.delay()
else:
some_task()
Можно также создать декоратор, который делает то же самое, что красивее, но, возможно, сложнее поддерживать?