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)
