Update from https://crrev.com/327068

testing/legion/task_controller.py

 # Copyright 2015 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Defines the task controller library."""
 
 import argparse
 import datetime
 import logging
 import os
 import socket
 import subprocess
 import sys
 import tempfile
 import threading
 import xmlrpclib
 
 #pylint: disable=relative-import
 import common_lib
+import process
 
 ISOLATE_PY = os.path.join(common_lib.SWARMING_DIR, 'isolate.py')
 SWARMING_PY = os.path.join(common_lib.SWARMING_DIR, 'swarming.py')
 
 
 class Error(Exception):
   pass
 
 
 class ConnectionTimeoutError(Error):
@@ skipping 88 matching lines @@
     assert isinstance(level, (str, int))
     if isinstance(level, int):
       level = logging.getLevelName(level)
     self._verbosity = level  #pylint: disable=attribute-defined-outside-init
 
   @classmethod
   def ReleaseAllTasks(cls):
     for task in cls._tasks:
       task.Release()
 
+  def Process(self, cmd, verbose=False, detached=False, cwd=None):
+    return process.ControllerProcessWrapper(
+        self.rpc, cmd, verbose, detached, cwd)
+
   def _CreateOTP(self):
     """Creates the OTP."""
     controller_name = socket.gethostname()
     test_name = os.path.basename(sys.argv[0])
     creation_time = datetime.datetime.utcnow()
     otp = 'task:%s controller:%s test:%s creation:%s' % (
         self._name, controller_name, test_name, creation_time)
     return otp
 
   def Create(self):
@@ skipping 61 matching lines @@
     if p.returncode != 0:
       raise Error(stderr)
 
   def OnConnect(self, ip_address):
     """Receives task ip address on connection."""
     self._ip_address = ip_address
     self._connected = True
     self._rpc = common_lib.ConnectToServer(self._ip_address)
     logging.info('%s connected from %s', self._name, ip_address)
     self._connect_event.set()