terminate kubernetes watch in case of unknown error (apache#43645)

astronomer · Nov 12, 2024 · bb12e6b · bb12e6b
1 parent 0a49acd
commit bb12e6b
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/providers/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py b/providers/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
@@ -773,8 +773,13 @@ def end(self) -> None:
             self.result_queue.join()
         except ConnectionResetError:
             self.log.exception("Connection Reset error while flushing task_queue and result_queue.")
+        except Exception:
+            self.log.exception("Unknown error while flushing task queue and result queue.")
         if self.kube_scheduler:
-            self.kube_scheduler.terminate()
+            try:
+                self.kube_scheduler.terminate()
+            except Exception:
+                self.log.exception("Unknown error while flushing task queue and result queue.")
         self._manager.shutdown()
 
     def terminate(self):