Skip to content

Commit a237895

Browse files
committed
Add Stacktrace when DagFileProcessorManager gets killed (apache#10681)
1 parent 0a76f57 commit a237895

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
@@ -22,6 +22,7 @@
2222
from __future__ import print_function
2323
from __future__ import unicode_literals
2424

25+
import inspect
2526
import logging
2627
import multiprocessing
2728
import os
@@ -788,6 +789,7 @@ def _exit_gracefully(self, signum, frame):
788789
Helper method to clean up DAG file processors to avoid leaving orphan processes.
789790
"""
790791
self.log.info("Exiting gracefully upon receiving signal %s", signum)
792+
self.log.debug("Current Stacktrace is: %s", '\n'.join(map(str, inspect.stack())))
791793
self.terminate()
792794
self.end()
793795
self.log.debug("Finished terminating DAG processors.")

0 commit comments

Comments
 (0)