Track SQLAlchemy session cleanness

gistfile1.py

@event.listens_for(Session, 'after_begin')
def session_after_begin(session, transaction, connection):
    session.info['clean'] = True


@event.listens_for(Session, 'after_flush')
def session_after_flush(session, flush_context):
    if session.new or session.dirty or session.deleted:
        session.info['clean'] = False


@event.listens_for(Session, 'after_commit')
def session_after_commit(session):
    session.info['clean'] = True


@event.listens_for(Session, 'after_rollback')
def session_after_rollback(session):
    session.info['clean'] = True


@event.listens_for(Session, 'after_bulk_update')
def session_after_bulk_update(update_context):
    update_context.session.info['clean'] = False


@event.listens_for(Session, 'after_bulk_delete')
def session_after_bulk_delete(delete_context):
    delete_context.session.info['clean'] = False