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