You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Xi Wang (JIRA)" <ji...@apache.org> on 2017/07/11 14:19:00 UTC
[jira] [Created] (AIRFLOW-1400) catchup=False caused exception
Xi Wang created AIRFLOW-1400:
--------------------------------
Summary: catchup=False caused exception
Key: AIRFLOW-1400
URL: https://issues.apache.org/jira/browse/AIRFLOW-1400
Project: Apache Airflow
Issue Type: Bug
Components: scheduler
Affects Versions: Airflow 1.8
Reporter: Xi Wang
When I set of the task with catchup=False, it threw a error as follow(logs/scheduler/my_dag_name):
[2017-07-10 15:13:12,534] {jobs.py:354} DagFileProcessor373 ERROR - Got an exception! Propagating...
Traceback (most recent call last):
File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 346, in helper
pickle_dags)
File "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 53, in wrapper
result = func(*args, **kwargs)
File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 1581, in process_file
self._process_dags(dagbag, dags, ti_keys_to_schedule)
File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 1171, in _process_dags
dag_run = self.create_dag_run(dag)
File "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 53, in wrapper
result = func(*args, **kwargs)
File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 776, in create_dag_run
if next_start <= now:
TypeError: can't compare datetime.datetime to NoneType
It seems next_start was not defined properly, (https://github.com/apache/incubator-airflow/blob/master/airflow/jobs.py#L777)
Any help is appreciated.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)