'Run \'function\' using parallel_simple, with an extra wrapper to handle
the necessary setup for continuous parsing, if possible. If continuous
parsing is already properly initialized then this should just work.
:param function: A callable to run in parallel given each machine.
:param machines: A list of machine names to be passed one per subcommand
invocation of function.
:param log: If True, output will be written to output in a subdirectory
named after each machine.
:param timeout: Seconds after which the function call should timeout.
:param return_results: If True instead of an AutoServError being raised
on any error a list of the results|exceptions from the function
called on each arg is returned.  [default: False]
:raise error.AutotestError: If any of the functions failed.'

def parallel_simple(self, function, machines, log=True, timeout=None, return_results=False):

    wrapper = self._make_parallel_wrapper(function, machines, log)
    return subcommand.parallel_simple(wrapper, machines, log=log, timeout=timeout, return_results=return_results)
