summaryrefslogtreecommitdiff
path: root/python/pgq/consumer.py
diff options
context:
space:
mode:
authorAsko Oja2012-09-19 12:42:34 +0000
committerAsko Oja2012-09-19 12:42:34 +0000
commitb14dedf1cf665a855b8ccbe5954c769417404b36 (patch)
treee57f549bd5fddff9d34088e66865c69c745540d9 /python/pgq/consumer.py
parent6da151f9f0f5e76617a9fd30ca0670a7fb0c414c (diff)
adjusted default keepalive_stats from 61 to 300 seconds
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 96d2180b..b3b45d18 100644
--- a/python/pgq/consumer.py
+++ b/python/pgq/consumer.py
@@ -135,7 +135,7 @@ class Consumer(skytools.DBScript):
# in how many seconds to write keepalive stats for idle consumers
# this stats is used for detecting that consumer is still running
- #keepalive_stats = 61
+ #keepalive_stats = 300
"""
# by default, use cursor-based fetch
@@ -219,7 +219,7 @@ class Consumer(skytools.DBScript):
expr = "ev_extra1 in (%s)" % ','.join(tfilt)
self.consumer_filter = expr
- self.keepalive_stats = self.cf.getint("keepalive_stats", 61)
+ self.keepalive_stats = self.cf.getint("keepalive_stats", 300)
def startup(self):
"""Handle commands here. __init__ does not have error logging."""