From 60a65b831ec6444803cb309bf12eb44282286a6c Mon Sep 17 00:00:00 2001 From: Valentin Lorentz Date: Thu, 14 Aug 2014 14:18:47 +0200 Subject: [PATCH] commands: Explicitely close the Queue object. --- src/commands.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/commands.py b/src/commands.py index d45d34078..f59442fda 100644 --- a/src/commands.py +++ b/src/commands.py @@ -121,11 +121,14 @@ def process(f, *args, **kwargs): p.join(timeout) if p.is_alive(): p.terminate() + q.close() raise ProcessTimeoutError("%s aborted due to timeout." % (p.name,)) try: v = q.get(block=False) except Queue.Empty: return None + finally: + q.close() if isinstance(v, Exception): raise v else: