singlebeat/beat.py
def sigterm_handler(self, signum, frame):
        """ When we get term signal
        if we are waiting and got a sigterm, we just exit.
        if we have a child running, we pass the signal first to the child
        then we exit.

        :param signum:
        :param frame:
        :return:
        """
        assert(self.state in ('WAITING', 'RUNNING', 'PAUSED'))
        logger.debug("our state %s", self.state)
        if self.state == 'WAITING':
            return self.ioloop.stop()

        if self.state == 'RUNNING':
            logger.debug('already running sending signal to child - %s',
                         self.sprocess.pid)
            os.kill(self.sprocess.pid, signum)
        self.ioloop.stop()
def sigterm_handler(self, signum, frame):
        assert(self.state in ('WAITING', 'RUNNING', 'PAUSED'))
        logger.debug("our state %s", self.state)
        if self.state == 'WAITING':
            return self.ioloop.stop()

        if self.state == 'RUNNING':
            logger.debug('already running sending signal to child - %s',
                         self.sprocess.pid)
            os.kill(self.sprocess.pid, signum)
        self.ioloop.stop()
def sigterm_handler ( self , signum , frame ) : assert ( self . state in ( 'WAITING' , 'RUNNING' , 'PAUSED' ) ) logger . debug ( "our state %s" , self . state ) if self . state == 'WAITING' : return self . ioloop . stop ( ) if self . state == 'RUNNING' : logger . debug ( 'already running sending signal to child - %s' , self . sprocess . pid ) os . kill ( self . sprocess . pid , signum ) self . ioloop . stop ( )
When we get term signal
        if we are waiting and got a sigterm, we just exit.
        if we have a child running, we pass the signal first to the child
        then we exit.

        :param signum:
        :param frame:
        :return:
When we get term signal if we are waiting and got a sigterm we just exit . if we have a child running we pass the signal first to the child then we exit .