CoopConsumer: Fix --unregister command.

DB function has 4 arguments not 3

diff --git a/python/pgq/coopconsumer.py b/python/pgq/coopconsumer.py
index cf97e472a5ff35857456d095927303aba4b3bdce..f4933ad3b6c6f371a8955fed90083610b11f39c3 100644 (file)
--- 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()