airflow/utils/dag_processing.py
def _exit_gracefully(self, signum, frame):
        """
        Helper method to clean up DAG file processors to avoid leaving orphan processes.
        """
        self.log.info("Exiting gracefully upon receiving signal %s", signum)
        self.terminate()
        self.end()
        self.log.debug("Finished terminating DAG processors.")
        sys.exit(os.EX_OK)
def _exit_gracefully(self, signum, frame):
        self.log.info("Exiting gracefully upon receiving signal %s", signum)
        self.terminate()
        self.end()
        self.log.debug("Finished terminating DAG processors.")
        sys.exit(os.EX_OK)
def _exit_gracefully ( self , signum , frame ) : self . log . info ( "Exiting gracefully upon receiving signal %s" , signum ) self . terminate ( ) self . end ( ) self . log . debug ( "Finished terminating DAG processors." ) sys . exit ( os . EX_OK )
Helper method to clean up DAG file processors to avoid leaving orphan processes.
Helper method to clean up DAG file processors to avoid leaving orphan processes .