Add Stacktrace when DagFileProcessorManager gets killed (apache#10681)

rajatsri28 · Sep 3, 2020 · faaf179 · faaf179
1 parent 57fd479
commit faaf179
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/airflow/utils/dag_processing.py b/airflow/utils/dag_processing.py
@@ -18,6 +18,7 @@
 """Processes DAGs."""
 import enum
 import importlib
+import inspect
 import logging
 import multiprocessing
 import os
@@ -633,6 +634,7 @@ def _exit_gracefully(self, signum, frame):  # pylint: disable=unused-argument
         Helper method to clean up DAG file processors to avoid leaving orphan processes.
         """
         self.log.info("Exiting gracefully upon receiving signal %s", signum)
+        self.log.debug("Current Stacktrace is: %s", '\n'.join(map(str, inspect.stack())))
         self.terminate()
         self.end()
         self.log.debug("Finished terminating DAG processors.")