techrec/server/maint.py

from __future__ import print_function
import sys
import logging

from sqlalchemy import inspect

from .config_manager import get_config
from .db import RecDB

def cleanold_cmd(options):
    log = logging.getLogger('cleanold')
    log.debug("starting cleanold[%d]" % options.minage)
    db = RecDB(get_config()['DB_URI'])
    res = db.get_not_completed(options.minage*3600*24)
    count = len(res)
    if options.pretend:
        for rec in res:
            print(rec)
    else:
        for rec in res:
            logging.info("Deleting " + str(rec))
            s = inspect(rec).session
            s.delete(rec)
            s.commit()
        logging.info("Cleanold complete: %d deleted" % count)
    sys.exit(0)

# vim: set ai ts=4 sw=4 et: