Я использую Flask -SQLAlchemy с сельдереем. Они плохо играют вместе, если задача Celery занимает много времени, например, когда она выполняется, когда происходит фиксация, соединение MySQL истекло и «пропало».
Можно ли выполнить изменяет объект SQLAlchemy, пытается выполнить фиксацию, а в случае неудачи открывает новый сеанс, присоединяет объекты к новому сеансу и фиксирует их? Если так, то как? Какая функция SQLAlchemy может сделать это? Или теперь, когда фиксация завершилась неудачно, поскольку сеанс завершен, объекты SQLAlchemy признаны недействительными и вся работа над ними должна быть выполнена снова?