Автоматический откат SQLALCHEMY

#python #postgresql #flask #sqlalchemy #flask-sqlalchemy

#python #postgresql #flask #sqlalchemy #flask-sqlalchemy

Вопрос:

Я получаю откаты автоматически. Вот мой код:

 @socketio.on('update2')
def update_table_infocorp(trigger):
    checknotprocess = Infocorp.query.filter(Infocorp.Procesado == False)

    for row in checknotprocess:
        getidentityuser = Usuarios.query.filter(Usuarios.id_user == row.id_user).first()
        getidentityconsulta = Consolidado.query.filter(Consolidado.id_user == row.id_user and
                                                       (Consolidado.numdocumento == getidentityuser.numdocumento)).first()
        if not getidentityconsulta:
            # print("No se encontro la consulta relacionada al usuario.")
            test = True
        else:
            sentinelresult = getsentinel(getidentityuser.tipodocumento, getidentityuser.numdocumento, row.id_consulta,
                                         getidentityconsulta.solicitudes_id)
            print(getidentityconsulta.solicitudes_id)
            print(getidentityuser.tipodocumento)
            if sentinelresult == True:
                continue
            else:
                print("Ocurrio un error")

    resultadoquery = Infocorp.query.filter(Infocorp.Procesado == True)
    datatransform = InfocorpSchema(many=True)
    datatransformresult = datatransform.dump(resultadoquery)
    emit('nuevatableinfocorp', datatransformresult, broadcast=True)
  

И это мои журналы:

введите описание изображения здесь

Я надеюсь, что вы сможете мне помочь, потому что это влияет на другие системы, которые используют ту же базу данных.

Комментарии:

1. Если вы не commit проводите свои сеансы, они будут ROLLBACK , когда они будут закрыты.

2. Привет @snakecharmerb в этом случае, куда я должен добавить коммит?