code: def kill_processes(self):
          
          LOGGER.critical('Max shutdown exceeded, forcibly exiting')
          processes = self.active_processes(False)
          while processes:
              for proc in self.active_processes(False):
                  if int(proc.pid) != int(os.getpid()):
                      LOGGER.warning('Killing %s (%s)', proc.name, proc.pid)
                      try:
                          os.kill(int(proc.pid), signal.SIGKILL)
                      except OSError:
                          pass
                  else:
                      LOGGER.warning('Cowardly refusing kill self (%s, %s)',
                                     proc.pid, os.getpid())
              time.sleep(0.5)
              processes = self.active_processes(False)
  
          LOGGER.info('Killed all children')
          return self.set_state(self.STATE_STOPPED)
docs: Gets called on shutdown by the timer when too much time has gone by,
          calling the terminate method instead of nicely asking for the consumers
          to stop.