You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Anant Mistry (JIRA)" <ji...@apache.org> on 2018/01/09 16:17:00 UTC
[jira] [Created] (AIRFLOW-1977) @once, @daily, etc
schedule_interval is failing
Anant Mistry created AIRFLOW-1977:
-------------------------------------
Summary: @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
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
(v6.4.14#64029)