__init__.py 文件源码

def receive_after_update(mapper, connection, target):
    """ listen for the 'after_update' event """
    @event.listens_for(Session, "before_commit", once=True)
    def receive_before_commit(session):
        paper_rating = session.query(PaperRating).filter_by(paper_id=target.paper_id).first()
        user_paper_ratings = session.query(UserPaperRating).filter_by(paper_id=target.paper_id).all()
        update_value(paper_rating, user_paper_ratings)