rafficghani opened a new issue, #23682:
URL: https://github.com/apache/airflow/issues/23682
### Apache Airflow version
2.2.2
### What happened
The scheduler goes down
[2022-05-12 11:14:06,586] {scheduler_job.py:1114} INFO - Resetting orphaned
tasks for active dag runs
[2022-05-12 11:14:06,806] {scheduler_job.py:644} ERROR - Exception when
executing SchedulerJob._run_scheduler_loop
Traceback (most recent call last):
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/airflow/jobs/scheduler_job.py",
line 628, in _execute
self._run_scheduler_loop()
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/airflow/jobs/scheduler_job.py",
line 721, in _run_scheduler_loop
next_event = timers.run(blocking=False)
File "/usr/lib64/python3.6/sched.py", line 154, in run
action(*argument, **kwargs)
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/airflow/utils/event_scheduler.py",
line 36, in repeat
action(*args, **kwargs)
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/airflow/utils/session.py",
line 70, in wrapper
return func(*args, session=session, **kwargs)
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/airflow/jobs/scheduler_job.py",
line 1117, in adopt_or_reset_orphaned_tasks
for attempt in run_with_db_retries(logger=self.log):
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/tenacity/__init__.py", line
382, in __iter__
do = self.iter(retry_state=retry_state)
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/tenacity/__init__.py", line
349, in iter
return fut.result()
File "/usr/lib64/python3.6/concurrent/futures/_base.py", line 425, in
result
return self.__get_result()
File "/usr/lib64/python3.6/concurrent/futures/_base.py", line 384, in
__get_result
raise self._exception
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/airflow/jobs/scheduler_job.py",
line 1162, in adopt_or_reset_orphaned_tasks
to_reset = self.executor.try_adopt_task_instances(tis_to_reset_or_adopt)
File
"/airflow/airflowvirt/lib64/python3.6/site-packages/airflow/executors/celery_executor.py",
line 485, in try_adopt_task_instances
self.adopted_task_timeouts[ti.key] = ti.queued_dttm +
self.task_adoption_timeout
TypeError: unsupported operand type(s) for +: 'NoneType' and
'datetime.timedelta'
[2022-05-12 11:14:08,027] {process_utils.py:100} INFO - Sending
Signals.SIGTERM to GPID 3929915
### What you think should happen instead
_No response_
### How to reproduce
_No response_
### Operating System
Redhat x86_64 GNU/Linux
### Versions of Apache Airflow Providers
_No response_
### Deployment
Virtualenv installation
### Deployment details
_No response_
### Anything else
_No response_
### Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
