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