Clean up extreme verbosity of logs in test harness.

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 46 matching lines @@
     def GetCurrentActiveCount():
       """Returns the (number of active jobs, first active job)."""
       active_count = 0
       active_job = None
       for parallel_job in parallel_jobs:
         if parallel_job.is_alive():
           active_count += 1
           if not active_job:
             active_job = parallel_job
 
-      return (active_count, parallel_job)
+      return (active_count, active_job)
 
+    first_time = True
     start_time = time.time()
     while (time.time() - start_time) < cls.MAX_TIMEOUT_SECONDS:
       (active_count, active_job) = GetCurrentActiveCount()
       if active_count == 0:
         return
       else:
-        print >> sys.stderr, (
-            'Process Pool Active: Waiting on %d/%d jobs to complete' %
-            (active_count, len(parallel_jobs)))
+        if not first_time:
+          print (
+              'Process Pool Active: Waiting on %d/%d jobs to complete' %
+              (active_count, len(parallel_jobs)))
+        else:
+          first_time = False
+
         active_job.join(cls.SLEEP_TIMEOUT_SECONDS)
         time.sleep(5) # Prevents lots of printing out as job is ending.
 
     for parallel_job in parallel_jobs:
       if parallel_job.is_alive():
         parallel_job.terminate()
 
     raise ParallelJobTimeoutError('Exceeded max time of %d seconds to wait for '
                                   'job completion.' % cls.MAX_TIMEOUT_SECONDS)
 
@@ skipping 48 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]