CODEWITHSUNDEEP
pythonapscheduler
yshalenyk
yshalenyk

Reputation: 45

APScheduler repeat jobs after previous run has finished

I'm running two jobs with APScheduler with GeventScheduler. But I want this jobs to run with pause, for example 1 minute and after the previous run has finished all tasks repeat this jobs. How can I achieve this?

Upvotes: 2

Views: 1777

Answers (1)

Mark Zhang
Mark Zhang

Reputation: 1208

This is worked for me

def execution_listener(event):
    job_id = event.job_id
    if event.exception:
        logging.error('job_id={} error!'.format(event.job_id))
    else:
        logging.info('job_id={} success'.format(event.job_id))
        # check that the executed job is the first job
        if job_id == CONST.JOB_ID.WORKEXP_CUT:   
             run_job_now(job_id, arg_dict)# run ypur job


def run_job_now(job_id, arg_dict):
    logging.info('id={} start'.format(job_id))
    job = scheduler.get_job(job_id)
    if job:
        job.modify(next_run_time=datetime.datetime.now())
    else:
        scheduler.add_job(next_run_time=datetime.datetime.now(), **arg_dict) 

scheduler.add_listener(execution_listener, EVENT_JOB_EXECUTED | EVENT_JOB_ERROR)

Upvotes: 2

Related Questions