Уведомления

Группа в Telegram: @pythonsu

#1 Дек. 5, 2013 13:50:42

plusplus
От:
Зарегистрирован: 2009-01-05
Сообщения: 418
Репутация: +  15  -
Профиль   Отправить e-mail  

Обеспечение запуска только одной копии periodic task в celery.

Нужно, чтобы задание, выполняемое планировщиком celery не запускалось, если предыдущий его запуск еще не отработал. Нашел пример, в нём используется django cache. У меня flask, но, собственно, сами задания с ним не связаны. Подскажите где мне хранить данные о запущенных заданиях? Пробовал использовать CacheBackend celery, сохранял запущенные задания в памяти, но это не работает, видимо потому что celery запускает каждый Worker отдельным процессом. Можно ли как-то использовать Flask-Cache? В общем, как лучше всего это сделать, подскажите, пожалуйста.



Офлайн

#2 Дек. 5, 2013 20:40:07

reclosedev
От: Н.Новгород
Зарегистрирован: 2012-03-29
Сообщения: 870
Репутация: +  173  -
Профиль   Отправить e-mail  

Обеспечение запуска только одной копии periodic task в celery.

Если redis используется можно взять Redis.lock()

Офлайн

Board footer

Модераторировать

Powered by DjangoBB

Lo-Fi Version