| Index: bin/au_test_harness/parallel_test_job.py
|
| diff --git a/bin/au_test_harness/parallel_test_job.py b/bin/au_test_harness/parallel_test_job.py
|
| index c84ef4401186de41c719fe7e627a06aff6f5f209..096ec170432a06b44f52b12b423f5aaddbc51040 100644
|
| --- a/bin/au_test_harness/parallel_test_job.py
|
| +++ b/bin/au_test_harness/parallel_test_job.py
|
| @@ -54,7 +54,6 @@ class ParallelJob(threading.Thread):
|
|
|
| def _Cleanup(self):
|
| """Releases semaphores for a waiting caller."""
|
| - cros_lib.Info('Completed job %s' % self)
|
| self._starting_semaphore.release()
|
| self._ending_semaphore.release()
|
|
|
| @@ -89,7 +88,7 @@ def RunParallelJobs(number_of_simultaneous_jobs, jobs, jobs_args,
|
| threads.append(thread)
|
|
|
| # Cache sudo access.
|
| - cros_lib.RunCommand(['sudo', 'echo', 'Starting test harness'],
|
| + cros_lib.RunCommand(['sudo', 'echo', 'Caching sudo credentials'],
|
| print_cmd=False, redirect_stdout=True,
|
| redirect_stderr=True)
|
|
|
| @@ -98,11 +97,9 @@ def RunParallelJobs(number_of_simultaneous_jobs, jobs, jobs_args,
|
| # Acquire blocks of num jobs reached and continues when a thread finishes.
|
| for next_thread in threads:
|
| job_start_semaphore.acquire(blocking=True)
|
| - cros_lib.Info('Starting job %s' % next_thread)
|
| next_thread.start()
|
|
|
| # Wait on the rest of the threads to finish.
|
| - cros_lib.Info('Waiting for threads to complete.')
|
| for thread in threads:
|
| while not join_semaphore.acquire(blocking=False):
|
| time.sleep(5)
|
|
|