summaryrefslogtreecommitdiff
path: root/python/pgq/consumer.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pgq/consumer.py')
-rw-r--r--python/pgq/consumer.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py
index 32fa9f76..57a74a3e 100644
--- a/python/pgq/consumer.py
+++ b/python/pgq/consumer.py
@@ -245,7 +245,7 @@ class Consumer(skytools.DBScript):
curs.execute(q, [self.queue_name, self.consumer_name])
return curs.fetchone()[0]
- def _flush_retry(self, curs, list):
+ def _flush_retry(self, curs, batch_id, list):
"""Tag retry events."""
retry = 0