code: def run(self, **kwargs):
          
          super().run(**kwargs)
          scheduler = self.scheduler_plugins[self.active_scheduler]()
  
          if not kwargs['no_daemon']:
              self.log.info('Starting {} worker with {} threads checking for new messages every {} seconds'.format(
                  scheduler.name,
                  kwargs['threads'],
                  kwargs['delay']
              ))
  
              for i in range(kwargs['threads']):
                  thd = threading.Thread(
                      target=self.execute_worker_thread,
                      args=(scheduler.execute_worker, kwargs['delay'])
                  )
                  thd.start()
          else:
              self.log.info('Starting {} worker for a single non-daemon execution'.format(
                  scheduler.name
              ))
              scheduler.execute_worker()
docs: Execute the worker thread.
  
          Returns:
              `None`