hamedhsn commented on issue #18989:
URL: https://github.com/apache/airflow/issues/18989#issuecomment-1043153983
some logs from scheduler
```
[2022-02-17 16:12:56,327] {kubernetes_executor.py:454} INFO - Found 0 queued
task instances
[2022-02-17 16:13:56,378] {kubernetes_executor.py:454} INFO - Found 0 queued
task instances
[2022-02-17 16:14:56,697] {kubernetes_executor.py:454} INFO - Found 0 queued
task instances
[2022-02-17 16:15:14,633] {scheduler_job.py:161} INFO - Exiting gracefully
upon receiving signal 15
[2022-02-17 16:15:15,636] {process_utils.py:100} INFO - Sending
Signals.SIGTERM to GPID 55
[2022-02-17 16:15:16,366] {process_utils.py:66} INFO - Process
psutil.Process(pid=2607, status='terminated', started='16:15:14') (2607)
terminated with exit code None
[2022-02-17 16:15:16,709] {process_utils.py:212} INFO - Waiting up to 5
seconds for processes to exit...
[2022-02-17 16:15:16,739] {process_utils.py:66} INFO - Process
psutil.Process(pid=2608, status='terminated', started='16:15:15') (2608)
terminated with exit code None
[2022-02-17 16:15:16,739] {process_utils.py:66} INFO - Process
psutil.Process(pid=55, status='terminated', exitcode=0, started='16:11:55')
(55) terminated with exit code 0
[2022-02-17 16:15:16,739] {kubernetes_executor.py:791} INFO - Shutting down
Kubernetes executor
[2022-02-17 16:15:16,740] {scheduler_job.py:650} ERROR - Exception when
executing Executor.end
Traceback (most recent call last):
File
"/home/airflow/.local/lib/python3.9/site-packages/airflow/jobs/scheduler_job.py",
line 628, in _execute
self._run_scheduler_loop()
File
"/home/airflow/.local/lib/python3.9/site-packages/airflow/jobs/scheduler_job.py",
line 730, in _run_scheduler_loop
time.sleep(min(self._scheduler_idle_sleep_time, next_event))
File
"/home/airflow/.local/lib/python3.9/site-packages/airflow/jobs/scheduler_job.py",
line 164, in _exit_gracefully
sys.exit(os.EX_OK)
SystemExit: 0
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File
"/home/airflow/.local/lib/python3.9/site-packages/airflow/jobs/scheduler_job.py",
line 648, in _execute
self.executor.end()
File
"/home/airflow/.local/lib/python3.9/site-packages/airflow/executors/kubernetes_executor.py",
line 793, in end
self._flush_task_queue()
File
"/home/airflow/.local/lib/python3.9/site-packages/airflow/executors/kubernetes_executor.py",
line 746, in _flush_task_queue
self.log.debug('Executor shutting down, task_queue approximate size=%d',
self.task_queue.qsize())
File "<string>", line 2, in qsize
File "/usr/local/lib/python3.9/multiprocessing/managers.py", line 809, in
_callmethod
conn.send((self._id, methodname, args, kwds))
File "/usr/local/lib/python3.9/multiprocessing/connection.py", line 211,
in send
self._send_bytes(_ForkingPickler.dumps(obj))
File "/usr/local/lib/python3.9/multiprocessing/connection.py", line 416,
in _send_bytes
self._send(header + buf)
File "/usr/local/lib/python3.9/multiprocessing/connection.py", line 373,
in _send
n = write(self._handle, buf)
BrokenPipeError: [Errno 32] Broken pipe
[2022-02-17 16:15:16,742] {process_utils.py:100} INFO - Sending
Signals.SIGTERM to GPID 55
[2022-02-17 16:15:16,742] {scheduler_job.py:655} INFO - Exited execute loop
```
--
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]
