diff --git a/src/libprs500/parallel.py b/src/libprs500/parallel.py index f349ee09d3..412a062dd1 100644 --- a/src/libprs500/parallel.py +++ b/src/libprs500/parallel.py @@ -112,7 +112,11 @@ class Server(object): cmd = prefix + 'from libprs500.parallel import run_job; run_job(\'%s\')'%binascii.hexlify(job_data) if not monitor: - popen([python, '-c', cmd]) + p = popen([python, '-c', cmd], stdout=subprocess.PIPE, stdin=subprocess.PIPE, + stderr=subprocess.PIPE) + p.stdout.close() + p.stdin.close() + p.stderr.close() return output = open(os.path.join(job_dir, 'output.txt'), 'wb')