def restart()

in provider/consumer.py [0:0]

• 19 lines of code
• 4 McCabe index (conditional complexity)

    def restart(self):
        if self.desiredState() == Consumer.State.Dead:
            logging.info('[{}] Request to restart a consumer that is already slated for deletion.'.format(self.trigger))
            return

        timeBetweenRestarts = datetime.now() - self.__lastRestart
        self.__lastRestart = datetime.now()

        if timeBetweenRestarts.total_seconds() >= seconds_in_day:
            self.__restartCount = 1
        else:
            self.__restartCount += 1

        logging.info('[{}] Quietly shutting down consumer for restart'.format(self.trigger))
        self.setDesiredState(Consumer.State.Restart)
        self.process.join()
        logging.info('Consumer has shut down')

        # user may have interleaved a request to delete the trigger, check again
        if self.desiredState() != Consumer.State.Dead:
            logging.info('[{}] Starting new consumer thread'.format(self.trigger))
            self.sharedDictionary = newSharedDictionary()
            self.process = ConsumerProcess(self.trigger, self.params, self.sharedDictionary)
            self.process.start()