десяток селери-тасок, к каждой таске привязано событие на выполнение, которое гарантированно отрабатывает. В каждом событии я создаю SQLAlchemy сессию с помощью sessionmaker(), начинаю транзакцию, выполняю один update() запрос, закрываю транзакцию. При этом часть транзакций отрабатывает, а часть - нет (без каких-либо ошибок). Как сделать, чтобы отрабатывали все транзакции? Я же создаю отдельную сессию для каждой таски? Мне даже не нужно, чтобы они отработали асинхронно, главное - чтоб отработали
таски случайным образом, не одни и те же строки обновляют?
не, каждая таска свою союственную стркоу обновляет
Сложно без кода. Но выглядит так что таски кто-то убивает раньше чем они отработают. логируй. или сам комить.
таски точно отрабатывают, это я проверил с помощью принтов)
Обсуждают сегодня