hack: cascadedconsumer send standby info
authorMarko Kreen <markokr@gmail.com>
Tue, 12 Oct 2010 12:50:12 +0000 (15:50 +0300)
committerMarko Kreen <markokr@gmail.com>
Tue, 12 Oct 2010 12:50:12 +0000 (15:50 +0300)
python/pgq/cascade/consumer.py

index c4315ef31ddf8443f948b97c7bb53a091605d165..44a85ced4d999d11bea1e91f34defba9627459a0 100644 (file)
@@ -175,6 +175,8 @@ class CascadedConsumer(Consumer):
         # extra sleep
         time.sleep(10*self.loop_delay)
 
+        self.log.info('{standby: 1}')
+
     def work(self):
         """Refresh state before calling Consumer.work()."""