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) |