docs: async def clear_queue(self):
          """Reset the executor queue channel to an empty state."""
          conn = await self._make_connection()
          try:
              script = """
                  local keys = redis.call('KEYS', ARGV[1])
                  redis.call('DEL', unpack(keys))
              """
              await conn.eval(
                  script,
                  keys=[],
                  args=['*{}*'.format(settings.FLOW_MANAGER['REDIS_PREFIX'])],
              )
          finally:
              conn.close()