__init__.py 文件源码

def clean_harvest_log(condition):
    Session.query(HarvestLog).filter(HarvestLog.created <= condition)\
                                .delete(synchronize_session=False)
    try:
        Session.commit()
    except InvalidRequestError:
        Session.rollback()
        log.error('An error occurred while trying to clean-up the harvest log table')

    log.info('Harvest log table clean-up finished successfully')