Parcourir la source

Pool: For some reason in some places ValueError can't be catched when doing BoundedSemaphore.release, so trying with except Exception instead

Ask Solem il y a 14 ans
Parent
commit
a648444129
1 fichiers modifiés avec 2 ajouts et 2 suppressions
  1. 2 2
      celery/concurrency/processes/pool.py

+ 2 - 2
celery/concurrency/processes/pool.py

@@ -331,7 +331,7 @@ class ResultHandler(PoolThread):
             if putlock is not None:
                 try:
                     putlock.release()
-                except ValueError:
+                except Exception:
                     pass
             try:
                 cache[job]._set(i, obj)
@@ -371,7 +371,7 @@ class ResultHandler(PoolThread):
         if putlock is not None:
             try:
                 putlock.release()
-            except ValueError:
+            except Exception:
                 pass
 
         while cache and self._state != TERMINATE: