code: def execute_with_client(quiet=False,
                          bootstrap_server=False,
                          create_client=True):
      
      def wrapper(f):
  
          def wrapper2(self, *args, **kwargs):
              client = self.current_client(
                  quiet=quiet,
                  bootstrap_server=bootstrap_server,
                  create_client=create_client)
              if client and client.running:
                  return f(self, client, *args, **kwargs)
          return wrapper2
  
      return wrapper
docs: Decorator that gets a client and performs an operation on it.