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