diff options
author | Andy McCurdy <andy@andymccurdy.com> | 2011-06-01 01:08:10 -0700 |
---|---|---|
committer | Andy McCurdy <andy@andymccurdy.com> | 2011-06-01 01:08:10 -0700 |
commit | 2c4b66d40d34f71742e9a0bf5c4721eee66fc6a1 (patch) | |
tree | 2a0b27dc0fe740d2c19d17af36008d4538498fbd /redis/client.py | |
parent | 47a4a7e339ea9c4243ea14303d7234f0de13f959 (diff) | |
download | redis-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.py | 10 |
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() |