Skip to content

Commit 3930070

Browse files
committed
Add Stacktrace when DagFileProcessorManager gets killed
1 parent 70f05ac commit 3930070

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

airflow/utils/dag_processing.py

+2
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
"""Processes DAGs."""
1919
import enum
2020
import importlib
21+
import inspect
2122
import logging
2223
import multiprocessing
2324
import os
@@ -693,6 +694,7 @@ def _exit_gracefully(self, signum, frame): # pylint: disable=unused-argument
693694
Helper method to clean up DAG file processors to avoid leaving orphan processes.
694695
"""
695696
self.log.info("Exiting gracefully upon receiving signal %s", signum)
697+
self.log.debug("Current Stacktrace is: %s", '\n'.join(map(str, inspect.stack())))
696698
self.terminate()
697699
self.end()
698700
self.log.debug("Finished terminating DAG processors.")

0 commit comments

Comments
 (0)