update.py 文件源码

def run_update(parsed_args):
    update = update_registry.get(parsed_args.fn)

    start = time()

    #convenience method for handling an doi
    if parsed_args.doi:
        from models.doi import Publication
        my_pub = db.session.query(Publication).filter(Publication.doi==parsed_args.doi).first()
        parsed_args.id = my_pub.id
        print u"Got database for this doi: {}".format(my_pub.id)

    update.run(
        use_rq=parsed_args.rq,
        obj_id=parsed_args.id,  # is empty unless updating just one row
        min_id=parsed_args.after,  # is empty unless minimum id
        num_jobs=parsed_args.limit,
        chunk_size=parsed_args.chunk
    )

    db.session.remove()
    print "finished update in {}sec".format(elapsed(start))