setconsumer fixes

1 files changed, 2 insertions, 2 deletions

diff --git a/python/pgq/rawconsumer.py b/python/pgq/rawconsumer.py
index 0cff4b2a..c1df916d 100644
--- a/python/pgq/rawconsumer.py
+++ b/python/pgq/rawconsumer.py
@@ -31,7 +31,7 @@ class RawQueue:
 
         return self.batch_id
 
-    def finish_batch(self, curs, batch_id): pass
+    def finish_batch(self, curs, batch_id):
         q = "select * from pgq.finish_batch(%s)"
         curs.execute(q, [self.batch_id])
 
@@ -46,6 +46,6 @@ class RawQueue:
 
     def finish_bulk_insert(self, curs):
         pgq.bulk_insert_events(curs, self.bulk_insert_buf,
-                               self.bulk_insert_fields, self.queue_name):
+                               self.bulk_insert_fields, self.queue_name)
         self.bulk_insert_buf = []