Ask Solem il y a 9 ans
Parent
commit
bc964c4bd4
3 fichiers modifiés avec 3 ajouts et 2 suppressions
  1. 1 1
      celery/backends/couchbase.py
  2. 1 1
      celery/canvas.py
  3. 1 0
      funtests/suite/test_leak.py

+ 1 - 1
celery/backends/couchbase.py

@@ -39,7 +39,7 @@ class CouchBaseBackend(KeyValueStoreBackend):
     timeout = 2.5
     transcoder = None
     # supports_autoexpire = False
-    
+
     # Use str as couchbase key not bytes
     key_t = str_t
 

+ 1 - 1
celery/canvas.py

@@ -392,7 +392,7 @@ class chain(Signature):
 
         try:
             tasks, results = self._frozen
-        except (AttributeError, ValueError):
+        except (AttributeError, ValueError, TypeError):
             tasks, results = self.prepare_steps(
                 args, self.tasks, root_id, link_error, app,
                 task_id, group_id, chord,

+ 1 - 0
funtests/suite/test_leak.py

@@ -127,5 +127,6 @@ class test_leaks(LeakFunCase):
         finally:
             self.app.conf.BROKER_POOL_LIMIT = pool_limit
 
+
 if __name__ == '__main__':
     unittest.main()