code: def execute_task(f, args, kwargs, user_ns):
      
      fname = getattr(f, '__name__', 'f')
      prefix = "parsl_"
      fname = prefix + "f"
      argname = prefix + "args"
      kwargname = prefix + "kwargs"
      resultname = prefix + "result"
  
      user_ns.update({fname: f,
                      argname: args,
                      kwargname: kwargs,
                      resultname: resultname})
  
      code = "{0} = {1}(*{2}, **{3})".format(resultname, fname,
                                             argname, kwargname)
      try:
          exec(code, user_ns, user_ns)
  
      except Exception as e:
          logger.warning("Caught exception; will raise it: {}".format(e))
          raise e
  
      else:
          return user_ns.get(resultname)
docs: Deserialize the buffer and execute the task.
  
      # Returns the result or exception.