diff --git a/shepherd/scheduler.py b/shepherd/scheduler.py index 08a0554..c747526 100644 --- a/shepherd/scheduler.py +++ b/shepherd/scheduler.py @@ -130,12 +130,12 @@ def save_jobs(): raise Exception("Could not save scheduler job " + job.id+" - Trigger is not a CronTrigger") saved_jobs.append(job.id) - if next_job_time is not None: - if job.next_run_time < next_job_time: + if hasattr(job,"next_run_time"): + if next_job_time is not None: + if job.next_run_time < next_job_time: + next_job_time = job.next_run_time + else: next_job_time = job.next_run_time - else: - - next_job_time = job.next_run_time with open(joblist_path+".writing", 'w+') as f: for saved_job in saved_jobs: