Fix bug where if we get an exception an no output we don't hang.

au_test_harness/parallel_test_job.py

 # Copyright (c) 2011 The Chromium OS Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Module containing methods/classes related to running parallel test jobs."""
 
 import multiprocessing
 import sys
 import time
 
@@ skipping 86 matching lines @@
     number_of_simultaneous_jobs:  Max number of parallel_jobs to be run in
       parallel.
     jobs:  Array of methods to run.
     jobs_args:  Array of args associated with method calls.
     print_status: True if you'd like this to print out .'s as it runs jobs.
   Returns:
     Returns an array of results corresponding to each parallel_job.
   """
   def ProcessOutputWrapper(func, args, output):
     """Simple function wrapper that puts the output of a function in a queue."""
-    output.put(func(*args))
+    try:
+      output.put(func(*args))
+    except:
+      output.put('')
+      raise
+    finally:
+      output.close()
 
   assert len(jobs) == len(jobs_args), 'Length of args array is wrong.'
   # Cache sudo access.
   cros_lib.RunCommand(['sudo', 'echo', 'Caching sudo credentials'],
                       print_cmd=False, redirect_stdout=True,
                       redirect_stderr=True)
 
   parallel_jobs = []
   output_array = []
 
@@ skipping 10 matching lines @@
     output_array.append(output)
 
   # We use a semaphore to ensure we don't run more jobs than required.
   # After each parallel_job finishes, it releases (increments semaphore).
   for next_parallel_job in parallel_jobs:
     job_start_semaphore.acquire(block=True)
     next_parallel_job.start()
 
   ParallelJob.WaitUntilJobsComplete(parallel_jobs)
   return [output.get() for output in output_array]