[
https://issues.apache.org/jira/browse/AIRFLOW-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sajid Sajid reassigned AIRFLOW-1253:
------------------------------------
Assignee: Sajid Sajid
> Jobs are not scheduled
> ----------------------
>
> Key: AIRFLOW-1253
> URL: https://issues.apache.org/jira/browse/AIRFLOW-1253
> Project: Apache Airflow
> Issue Type: Bug
> Components: scheduler
> Affects Versions: 1.8.1
> Reporter: Liran Y
> Assignee: Sajid Sajid
> Priority: Critical
>
> Jobs are not scheduled for me in airflow when using 24 hour cron (example: 0
> 7 * * *)
> I tried to debug jobs.py and it seems the following is causing it not to run
> (line 857):
> {code}
> if next_run_date and period_end and period_end <= datetime.now():
> {code}
> I don't understand the logic here.
> This is what's in the above variables:
> {noformat}
> next_run_date=2017-05-30 07:00:00
> period_end=2017-05-31 07:00:00
> datetime.now()=2017-05-30 07:01:22
> {noformat}
> next_run_date reflects the next run date of the DAG which is correct (today
> at 07:00)
> period_end reflects when will be the next-next run which is also correct
> (tomorrow)
> The DAG needs to run in between.
> So the IF above should be:
> {code}
> if next_run_date and period_end and period_end >= datetime.now():
> {code}
> Am I missing something?
> Thanks
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
