Don't mask ConnectionError in Pipeline.execute()

mitsuhiko · Jul 12, 2011 · 9e918fd · 9e918fd
1 parent 4bc9b77
commit 9e918fd
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/redis/client.py b/redis/client.py
@@ -1342,10 +1342,10 @@ def execute(self):
             return execute(conn, stack)
         except ConnectionError:
             conn.disconnect()
-            # if we watching a variable, the watch is no longer valid since
-            # this conncetion has died.
+            # if we were watching a variable, the watch is no longer valid since
+            # this connection has died.
             if self.watching:
-                raise WatchError("Watched variable changed.")
+                raise
             return execute(conn, stack)
         finally:
             self.reset()