Add Stacktrace when DagFileProcessorManager gets killed (#10681)

This commit is contained in:
Sumit Maheshwari 2020-09-03 23:38:02 +05:30 коммит произвёл GitHub
Родитель 57fd4797e0
Коммит faaf1796fb
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 4AEE18F83AFDEB23
1 изменённых файлов: 2 добавлений и 0 удалений

Просмотреть файл

@ -18,6 +18,7 @@
"""Processes DAGs."""
import enum
import importlib
import inspect
import logging
import multiprocessing
import os
@ -633,6 +634,7 @@ class DagFileProcessorManager(LoggingMixin): # pylint: disable=too-many-instanc
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.")