[Android] Split out the instrumentation test runner, sharder, and dispatcher.

build/android/pylib/host_driven/python_test_sharder.py

 # Copyright (c) 2012 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.
 
 """Takes care of sharding the python-drive tests in multiple devices."""
 
 import copy
 import logging
 import multiprocessing
 
 from pylib.base import sharded_tests_queue
 from pylib.base.test_result import TestResults
-from pylib.instrumentation.run_java_tests import FatalTestException
 
 from python_test_caller import CallPythonTest
 
 
 def SetTestsContainer(tests_container):
   """Sets PythonTestSharder as a top-level field.
 
   PythonTestSharder uses multiprocessing.Pool, which creates a pool of
   processes. This is used to initialize each worker in the pool, ensuring that
   each worker has access to this shared pool of tests.
@@ skipping 108 matching lines @@
       pool = multiprocessing.Pool(len(self.attached_devices),
                                   SetTestsContainer,
                                   [PythonTestSharder.tests_container])
 
       # List of TestResults objects from each test execution.
       try:
         results_lists = pool.map(_DefaultRunnable, test_runners)
       except Exception:
         logging.exception('Unable to run tests. Something with the '
                           'PythonTestRunners has gone wrong.')
-        raise FatalTestException('PythonTestRunners were unable to run tests.')
+        raise Exception('PythonTestRunners were unable to run tests.')
 
       test_results = TestResults.FromTestResults(results_lists)
       # Accumulate passing results.
       all_passed += test_results.ok
       # If we have failed tests, map them to tests to retry.
       failed_tests = test_results.GetAllBroken()
       tests_to_run = self._GetTestsToRetry(self.tests,
                                            failed_tests)
 
       # Bail out early if we have no more tests. This can happen if all tests
@@ skipping 42 matching lines @@
       failed_tests: a list of SingleTestResults representing failed tests.
 
     Returns:
       A list of test objects which correspond to test names found in
       failed_tests, or an empty list if there is no correspondence.
     """
     failed_test_names = map(lambda t: t.test_name, failed_tests)
     tests_to_retry = [t for t in available_tests
                       if t.qualified_name in failed_test_names]
     return tests_to_retry