summaryrefslogtreecommitdiff
path: root/redis/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'redis/client.py')
-rw-r--r--redis/client.py3
1 files changed, 1 insertions, 2 deletions
diff --git a/redis/client.py b/redis/client.py
index 75fca53..b9b843c 100644
--- a/redis/client.py
+++ b/redis/client.py
@@ -1225,7 +1225,6 @@ class Pipeline(Redis):
if self.command_stack:
raise RedisError('Commands without an initial WATCH have already '
'been issued')
- self.transaction = True
self.explicit_transaction = True
def execute_command(self, *args, **kwargs):
@@ -1310,7 +1309,7 @@ class Pipeline(Redis):
def execute(self):
"Execute all the commands in the current pipeline"
stack = self.command_stack
- if self.transaction:
+ if self.transaction or self.explicit_transaction:
stack = [(('MULTI' ,), {})] + stack + [(('EXEC', ), {})]
execute = self._execute_transaction
else: