From 2733a617d77e4298f30b41516edf200c29ecf49c Mon Sep 17 00:00:00 2001 From: sirnicolaz Date: Sat, 17 Aug 2013 10:51:26 +0200 Subject: Add utility for pipelining within 'with' statement. --- redis/utils.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/redis/utils.py b/redis/utils.py index ee681bf..b7e7f46 100644 --- a/redis/utils.py +++ b/redis/utils.py @@ -14,3 +14,11 @@ def from_url(url, db=None, **kwargs): """ from redis.client import Redis return Redis.from_url(url, db, **kwargs) + + +from contextlib import contextmanager +@contextmanager +def pipeline(redis_obj): + p = redis_obj.pipeline() + yield p + p.execute() -- cgit v1.2.1