Schedule next job only if a reference start time can be determined

This commit is contained in:
jeremystretch 2022-12-08 15:46:44 -05:00
parent 23bd7ce9a7
commit 839f99d537

View File

@ -90,8 +90,9 @@ def run_report(job_result, *args, **kwargs):
logging.error(f"Error during execution of report {job_result.name}") logging.error(f"Error during execution of report {job_result.name}")
finally: finally:
# Schedule the next job if an interval has been set # Schedule the next job if an interval has been set
if job_result.interval: start_time = job_result.scheduled or job_result.started
new_scheduled_time = job_result.scheduled + timedelta(minutes=job_result.interval) if start_time and job_result.interval:
new_scheduled_time = start_time + timedelta(minutes=job_result.interval)
JobResult.enqueue_job( JobResult.enqueue_job(
run_report, run_report,
name=job_result.name, name=job_result.name,