docs: def handle(self, *args, **kwargs):
          """Run the executor listener. This method never returns."""
          listener = ExecutorListener(redis_params=getattr(settings, 'FLOW_MANAGER', {}).get('REDIS_CONNECTION', {}))
  
          def _killer(signum, frame):
              """Kill the listener on receipt of a signal."""
              listener.terminate()
          signal(SIGINT, _killer)
          signal(SIGTERM, _killer)
  
          async def _runner():
              """Run the listener instance."""
              if kwargs['clear_queue']:
                  await listener.clear_queue()
              async with listener:
                  pass
  
          loop = asyncio.new_event_loop()
          loop.run_until_complete(_runner())
          loop.close()