Index: au_test_harness/parallel_test_job.py |
diff --git a/au_test_harness/parallel_test_job.py b/au_test_harness/parallel_test_job.py |
index 5c563a03f51b46fecb0655001ac45e701ce83153..589b0af1bcbb9f8bab27e59cef82e316d811f100 100644 |
--- a/au_test_harness/parallel_test_job.py |
+++ b/au_test_harness/parallel_test_job.py |
@@ -64,17 +64,22 @@ class ParallelJob(multiprocessing.Process): |
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. |