airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Fokko Driesprong (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (AIRFLOW-1977) @once, @daily, etc schedule_interval is failing
Date Mon, 12 Feb 2018 21:19:00 GMT

     [ https://issues.apache.org/jira/browse/AIRFLOW-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Fokko Driesprong closed AIRFLOW-1977.
-------------------------------------
       Resolution: Fixed
    Fix Version/s: 1.10.0

> @once, @daily, etc schedule_interval is failing
> -----------------------------------------------
>
>                 Key: AIRFLOW-1977
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1977
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: scheduler, webserver, worker
>    Affects Versions: 1.9.0
>         Environment: Redhat 7, Redis and Postgres (RDS) in AWS 
>            Reporter: Anant Mistry
>            Assignee: Bolke de Bruin
>            Priority: Major
>             Fix For: 1.10.0
>
>
> This is an except from the scheduler log while attempting to run the SubDag example (example_subdag_operator)
> [2018-01-08 16:05:50,201] {jobs.py:1386} INFO - Processing example_subdag_operator
> [2018-01-08 16:05:50,209] {jobs.py:379} ERROR - Got an exception! Propagating...
> Traceback (most recent call last):
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 371, in helper
>     pickle_dags)
>   File "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper
>     result = func(*args, **kwargs)
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 1792, in process_file
>     self._process_dags(dagbag, dags, ti_keys_to_schedule)
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 1388, in _process_dags
>     dag_run = self.create_dag_run(dag)
>   File "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper
>     result = func(*args, **kwargs)
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 807, in create_dag_run
>     if next_start <= now:
> TypeError: can't compare datetime.datetime to NoneType
> [2018-01-08 16:05:50,214] {jobs.py:379} ERROR - Got an exception! Propagating...
> Traceback (most recent call last):
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 371, in helper
>     pickle_dags)
>   File "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper
>     result = func(*args, **kwargs)
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 1792, in process_file
>     self._process_dags(dagbag, dags, ti_keys_to_schedule)
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 1388, in _process_dags
>     dag_run = self.create_dag_run(dag)
>   File "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 50, in wrapper
>     result = func(*args, **kwargs)
>   File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 807, in create_dag_run
>     if next_start <= now:
> TypeError: can't compare datetime.datetime to NoneType
> [2018-01-08 16:05:50,618] {jobs.py:1627} INFO - Heartbeating the process manager
> Also while this DAG is enabled in the UI, all other DAGs end up stuck in the DAG Running
State (although no tasks are scheduled or run)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message