You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "jack (Jira)" <ji...@apache.org> on 2019/09/04 07:20:00 UTC

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

    [ https://issues.apache.org/jira/browse/AIRFLOW-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16922218#comment-16922218 ] 

jack commented on AIRFLOW-1253:
-------------------------------

Is this still an issue?

> 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
(v8.3.2#803003)