[ 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)