Найти - Пользователи
Полная версия: Обеспечение запуска только одной копии periodic task в celery.
Начало » Python для экспертов » Обеспечение запуска только одной копии periodic task в celery.
1
plusplus
Нужно, чтобы задание, выполняемое планировщиком celery не запускалось, если предыдущий его запуск еще не отработал. Нашел пример, в нём используется django cache. У меня flask, но, собственно, сами задания с ним не связаны. Подскажите где мне хранить данные о запущенных заданиях? Пробовал использовать CacheBackend celery, сохранял запущенные задания в памяти, но это не работает, видимо потому что celery запускает каждый Worker отдельным процессом. Можно ли как-то использовать Flask-Cache? В общем, как лучше всего это сделать, подскажите, пожалуйста.
reclosedev
Если redis используется можно взять Redis.lock()
This is a "lo-fi" version of our main content. To view the full version with more information, formatting and images, please click here.
Powered by DjangoBB