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 89befffe530175174deb4597f0ee8f84f1b4454e..483bd6948f8aa963e9a25296ee9d815333926ae1 100644 |
--- a/au_test_harness/parallel_test_job.py |
+++ b/au_test_harness/parallel_test_job.py |
@@ -104,7 +104,13 @@ def RunParallelJobs(number_of_simultaneous_jobs, jobs, jobs_args, |
""" |
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. |