Sfoglia il codice sorgente

PromiseProxy: Only remove original object if evaluation succeeded

Ask Solem 11 anni fa
parent
commit
5892ba2566
1 ha cambiato i file con 3 aggiunte e 1 eliminazioni
  1. 3 1
      celery/local.py

+ 3 - 1
celery/local.py

@@ -251,7 +251,9 @@ class PromiseProxy(Proxy):
             thing = Proxy._get_current_object(self)
             object.__setattr__(self, '__thing', thing)
             return thing
-        finally:
+        except:
+            raise
+        else:
             for attr in _clean:
                 try:
                     object.__delattr__(self, attr)