Повторное использование записи базы данных, созданной с помощью задачи Celery

Есть задача, которая при первом запуске создает запись базы данных {R). При втором запуске задача должна прочитать запись из базы данных, выполнить некоторые вычисления и вызвать внешний API. Первый и второй запуск происходят в цикле В случае одиночного запуска задачи проблем нет, но в случае циклов (на каждой итерации цикла создается новая задача и запускается в определенное время) возникает проблема. В очереди задач (для нее мы используем цветок) на каждой второй итерации происходит сбой задачи. Если добавить в конце цикла time.sleep(1), то иногда задачи работают правильно, а иногда - нет. Как избежать этой проблемы? Мы опасаемся, что задания для различных комбинаций двух пользователей, запущенные в одно и то же время, также будут аварийно завершаться. Есть ли какая-то проблема с одновременным запуском задач в Celery? Или что-то, что мы должны учитывать, задачи предназначены для запланированных платежей, поэтому они должны работать надежно

Вернуться на верх