Always create new pipeline object

mrjoes · May 15, 2014 · df79990 · df79990
1 parent ff1b2d7
commit df79990
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/toredis/client.py b/toredis/client.py
@@ -37,8 +37,6 @@ def __init__(self, io_loop=None):
 
         self._sub_callback = False
 
-        self._pipeline = None
-
     def connect(self, host='localhost', port=6379, callback=None):
         """
             Connect to redis server
@@ -257,6 +255,4 @@ def _reset(self):
         self._sub_callback = None
 
     def pipeline(self):
-        if not self._pipeline:
-             self._pipeline = Pipeline(self)
-        return self._pipeline
+        return Pipeline(self)