airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anant Mistry (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AIRFLOW-1977) @once, @daily, etc schedule_interval is failing
Date Tue, 09 Jan 2018 16:17:00 GMT
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)

Mime
View raw message