code: def _run_node_distribution_command(self, command, workunit):
      
      process = command.run(stdout=workunit.output('stdout'),
                            stderr=workunit.output('stderr'))
      return process.wait()
docs: Runs a NodeDistribution.Command for _execute_command and returns its return code.
  
      Passes any additional kwargs to command.run (which passes them, modified, to subprocess.Popen).
      Override this in a Task subclass to do something more complicated than just calling
      command.run() and returning the result of wait().
  
      :param NodeDistribution.Command command: The command to run.
      :param WorkUnit workunit: The WorkUnit the command is running under.
      :returns: returncode
      :rtype: int