From bf3ee2c79f9251c1cd9e6eb31288b1079c2f4015 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Mon, 4 Jul 2011 14:49:51 +0300 Subject: [PATCH] CoopConsumer: Fix --unregister command. DB function has 4 arguments not 3 --- python/pgq/coopconsumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/pgq/coopconsumer.py b/python/pgq/coopconsumer.py index cf97e472..f4933ad3 100644 --- a/python/pgq/coopconsumer.py +++ b/python/pgq/coopconsumer.py @@ -54,7 +54,7 @@ class CoopConsumer(Consumer): self.log.info("Unregistering consumer from source queue") db = self.get_database(self.db_name) cx = db.cursor() - cx.execute("select pgq_coop.unregister_consumer(%s, %s, %s)", + cx.execute("select pgq_coop.unregister_consumer(%s, %s, %s, 0)", [self.queue_name, self.consumer_name, self.subconsumer_name]) db.commit() -- 2.39.5