summaryrefslogtreecommitdiff
path: root/redis/client.py
diff options
context:
space:
mode:
authorAndy McCurdy <andy@andymccurdy.com>2011-06-01 01:08:10 -0700
committerAndy McCurdy <andy@andymccurdy.com>2011-06-01 01:08:10 -0700
commit2c4b66d40d34f71742e9a0bf5c4721eee66fc6a1 (patch)
tree2a0b27dc0fe740d2c19d17af36008d4538498fbd /redis/client.py
parent47a4a7e339ea9c4243ea14303d7234f0de13f959 (diff)
downloadredis-py-2c4b66d40d34f71742e9a0bf5c4721eee66fc6a1.tar.gz
pipelines need the response_callback love, too. grammar fixes in docs
Diffstat (limited to 'redis/client.py')
-rw-r--r--redis/client.py10
1 files changed, 8 insertions, 2 deletions
diff --git a/redis/client.py b/redis/client.py
index c14499c..14dde9e 100644
--- a/redis/client.py
+++ b/redis/client.py
@@ -196,7 +196,11 @@ class Redis(object):
atomic, pipelines are useful for reducing the back-and-forth overhead
between the client and server.
"""
- return Pipeline(self.connection_pool, transaction, shard_hint)
+ return Pipeline(
+ self.connection_pool,
+ self.response_callbacks,
+ transaction,
+ shard_hint)
def lock(self, name, timeout=None, sleep=0.1):
"""
@@ -1170,8 +1174,10 @@ class Pipeline(Redis):
ResponseError exceptions, such as those raised when issuing a command
on a key of a different datatype.
"""
- def __init__(self, connection_pool, transaction, shard_hint):
+ def __init__(self, connection_pool, response_callbacks, transaction,
+ shard_hint):
self.connection_pool = connection_pool
+ self.response_callbacks = response_callbacks
self.transaction = transaction
self.shard_hint = shard_hint
self.reset()