airflow/jobs.py
def _exit_gracefully(self, signum, frame):
        """
        Helper method to clean up processor_agent to avoid leaving orphan processes.
        """
        self.log.info("Exiting gracefully upon receiving signal %s", signum)
        if self.processor_agent:
            self.processor_agent.end()
        sys.exit(os.EX_OK)
def _exit_gracefully(self, signum, frame):
        """
        Helper method to clean up processor_agent to avoid leaving orphan processes.
        """
        self.log.info("Exiting gracefully upon receiving signal %s", signum)
        if self.processor_agent:
            self.processor_agent.end()
        sys.exit(os.EX_OK)
def _exit_gracefully ( self , signum , frame ) : self . log . info ( "Exiting gracefully upon receiving signal %s" , signum ) if self . processor_agent : self . processor_agent . end ( ) sys . exit ( os . EX_OK )
Helper method to clean up processor_agent to avoid leaving orphan processes.
Helper method to clean up processor_agent to avoid leaving orphan processes .