[GitHub] [airflow] sr-regify commented on issue #9046: TimeDeltaSensor and schedule_interval="@once" leads to crash

[GitBox <gi...@apache.org>]

sr-regify commented on issue #9046:
URL: https://github.com/apache/airflow/issues/9046#issuecomment-672975239


   ➜ airflow version
   1.10.10
   The above version reports the same issue. I found a pattern that, if there is any task the DAG unable to allocate the resources and continue to stay in running state then I changed the task status to **up for retry** 
   I got the error as below 
    TypeError: unsupported operand type(s) for +: 'NoneType' and 'datetime.timedelta'
   
   
   Process DagFileProcessor0-Process:
   Traceback (most recent call last):
     File "/Users/ABCl/opt/anaconda3/lib/python3.7/multiprocessing/process.py", line 297, in _bootstrap
       self.run()
     File "/Users/ABCl/opt/anaconda3/lib/python3.7/multiprocessing/process.py", line 99, in run
       self._target(*self._args, **self._kwargs)
     File "/Users/ABCl/opt/anaconda3/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 158, in _run_file_processor
       pickle_dags)
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/utils/db.py", line 74, in wrapper
       return func(*args, **kwargs)
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1611, in process_file
       self._process_dags(dagbag, dags, ti_keys_to_schedule)
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1295, in _process_dags
       self._process_task_instances(dag, tis_out)
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/utils/db.py", line 74, in wrapper
       return func(*args, **kwargs)
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 801, in _process_task_instances
       session=session):
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/utils/db.py", line 70, in wrapper
       return func(*args, **kwargs)
     File "/Users/ABCl/opt/anaconda3/lib/python3.7/site-packages/airflow/models/taskinstance.py", line 658, in are_dependencies_met
       session=session):
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/models/taskinstance.py", line 682, in get_failed_dep_statuses
       dep_context):
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/ti_deps/deps/base_ti_dep.py", line 106, in get_dep_statuses
       for dep_status in self._get_dep_statuses(ti, session, dep_context):
     File "/Users/Neel/opt/anaconda3/lib/python3.7/site-packages/airflow/ti_deps/deps/not_in_retry_period_dep.py", line 47, in _get_dep_statuses
       next_task_retry_date = ti.next_retry_datetime()
     File "/Users/ABC/opt/anaconda3/lib/python3.7/site-packages/airflow/models/taskinstance.py", line 729, in next_retry_datetime
       return self.end_date + delay
   TypeError: unsupported operand type(s) for +: 'NoneType' and 'datetime.timedelta'


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org