[jira] [Created] (AIRFLOW-1253) Jobs are not scheduled

[Liran Y (JIRA)]

Liran Y created AIRFLOW-1253:
--------------------------------

             Summary: 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
            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
(v6.3.15#6346)