projects
/
skytools.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
b337cac
)
hack: cascadedconsumer send standby info
author
Marko Kreen
<markokr@gmail.com>
Tue, 12 Oct 2010 12:50:12 +0000
(15:50 +0300)
committer
Marko Kreen
<markokr@gmail.com>
Tue, 12 Oct 2010 12:50:12 +0000
(15:50 +0300)
python/pgq/cascade/consumer.py
patch
|
blob
|
blame
|
history
diff --git
a/python/pgq/cascade/consumer.py
b/python/pgq/cascade/consumer.py
index c4315ef31ddf8443f948b97c7bb53a091605d165..44a85ced4d999d11bea1e91f34defba9627459a0 100644
(file)
--- a/
python/pgq/cascade/consumer.py
+++ b/
python/pgq/cascade/consumer.py
@@
-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()."""