[
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)
