worker.py 文件源码

def parse_crontab(line):
    args = line.split(' ')
    job_id = uuid.uuid5(uuid.NAMESPACE_DNS, line).hex
    cron, job = args[:5], Job(args[5:])
    db.status.push(job_id, ' '.join(cron))
    schedule = {}
    parse_schedule(cron[0], 'minute', [0, 60], schedule)
    parse_schedule(cron[1], 'hour', [0, 24], schedule)
    parse_schedule(cron[2], 'day', [1, 32], schedule)
    parse_schedule(cron[3], 'month', [1, 13], schedule)
    parse_schedule(cron[4], 'weekday', [0, 7], schedule)
    db.cron.push(job_id, job.path, job.args, job.method, schedule)