summaryrefslogtreecommitdiff
path: root/python/pgq/consumer.py
diff options
context:
space:
mode:
authorMarko Kreen2008-04-16 09:55:41 +0000
committerMarko Kreen2008-04-16 09:55:41 +0000
commit2e10c0cdeba86ade288e9fc4a0eaf8b0141f898e (patch)
treee2b443348eb762cbf76a5af3f84366c35d0c6928 /python/pgq/consumer.py
parent8277ba5546ced7a745d47ffc310964b761a98144 (diff)
fix more bugs - stats, trigger type
Diffstat (limited to 'python/pgq/consumer.py')
-rw-r--r--python/pgq/consumer.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py
index c44ba236..af02e4fd 100644
--- a/python/pgq/consumer.py
+++ b/python/pgq/consumer.py
@@ -295,8 +295,8 @@ class Consumer(skytools.DBScript):
def stat_end(self, count):
t = time.time()
- self.stat_add('count', count)
- self.stat_add('duration', t - self.stat_batch_start)
+ self.stat_put('count', count)
+ self.stat_put('duration', t - self.stat_batch_start)
class RemoteConsumer(Consumer):