diff --git a/apps/reader/models.py b/apps/reader/models.py
index b9123efb5..ed6a5dd2e 100644
--- a/apps/reader/models.py
+++ b/apps/reader/models.py
@@ -706,12 +706,17 @@ class MUserStory(mongo.Document):
 
         total = read_stories.count()
         print " ---> Syncing %s stories (%s)" % (total, user_id or feed_id)
-        pipeline = r.pipeline()
+        pipeline = None
         for i, read_story in enumerate(read_stories):
+            if not pipeline:
+                pipeline = r.pipeline()
             if (i+1) % 1000 == 0: 
                 print " ---> %s/%s" % (i+1, total)
+                pipeline.execute()
+                pipeline = r.pipeline()
             read_story.sync_redis(r, pipeline=pipeline)
-        pipeline.execute()
+        if pipeline:
+            pipeline.execute()
         
 class UserSubscriptionFolders(models.Model):
     """