londiste do-sync: actually reset the pgq params
authorMarko Kreen <markokr@gmail.com>
Wed, 8 Dec 2010 13:58:36 +0000 (15:58 +0200)
committerMarko Kreen <markokr@gmail.com>
Wed, 8 Dec 2010 13:58:36 +0000 (15:58 +0200)
python/londiste/playback.py

index d3fe584b4d37faa62d7604408f650ade5c6c763c..30dcc261b762b435767c9b29d60b4da5f35a5026 100644 (file)
@@ -413,6 +413,8 @@ class Replicator(CascadedWorker):
             if self.pgq_min_count or self.pgq_min_interval:
                 bak = (self.cur_tick, self.pgq_min_count, self.pgq_min_interval)
                 self.dsync_backup = bak
+                self.pgq_min_count = None
+                self.pgq_min_interval = None
         elif self.dsync_backup:
             self.pgq_min_count = self.dsync_backup[1]
             self.pgq_min_interval = self.dsync_backup[2]