diff options
| -rw-r--r-- | redis/client.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/redis/client.py b/redis/client.py index 4071d32..afa512a 100644 --- a/redis/client.py +++ b/redis/client.py @@ -2061,6 +2061,7 @@ class BasePipeline(object): response.insert(i, e) if len(response) != len(commands): + self.connection.disconnect() raise ResponseError("Wrong number of response items from " "pipeline execution") |