Przeglądaj źródła

TaskSetResult.join causes TypeError when timeout=None. Thanks Jerzy Kozera. Closes #31

Ask Solem 15 lat temu
rodzic
commit
7cb2855e93
1 zmienionych plików z 2 dodań i 1 usunięć
  1. 2 1
      celery/result.py

+ 2 - 1
celery/result.py

@@ -292,7 +292,8 @@ class TaskSetResult(object):
                 # queue.
                 return list(results)
             else:
-                if time.time() >= time_start + timeout:
+                if timeout is not None and \
+                        time.time() >= time_start + timeout:
                     on_timeout()
 
     @property