Перехватить ошибку соединения Celery и вернуться к синхронному выполнению - PullRequest
0 голосов
/ 30 января 2019

Я использую сельдерей с redis в качестве брокера на django и хотел бы звонить task.delay() только в случае успешного подключения к брокеру.В противном случае я намерен выполнить задачу синхронно с помощью task.apply() и заблокировать ее до завершения.Я думаю об этом так, чтобы я мог, по крайней мере, заставить приложение работать даже без настройки сервера Redis.

Мой вопрос заключается в том, как / где перехватить ошибку соединения или какие-либо идеи о том, как добиться этого.

Спасибо.

...