allow tasks without timeout

2012-08-30 08:05:09 -05:00
parent 6a9aa69c93
commit 04fe5199f1
4 changed files with 92 additions and 3 deletions
@@ -262,7 +262,8 @@ class MetaScheduler(threading.Thread):

            start = time.time()

-            while p.is_alive() and (time.time()-start < task.timeout):
+            while p.is_alive() and (
+                not task.timeout or time.time()-start < task.timeout):
                if tout:
                    try:
                        logging.debug(' partial output saved')