some scripts were not converted to new api

3 files changed, 3 insertions, 3 deletions

diff --git a/scripts/bulk_loader.py b/scripts/bulk_loader.py
index a098787e..3a78cc83 100755
--- a/scripts/bulk_loader.py
+++ b/scripts/bulk_loader.py
@@ -136,7 +136,7 @@ class BulkLoader(pgq.SerialConsumer):
     def __init__(self, args):
         pgq.SerialConsumer.__init__(self, "bulk_loader", "src_db", "dst_db", args)
 
-    def process_remote_batch(self, batch_id, ev_list, dst_db):
+    def process_remote_batch(self, src_db, batch_id, ev_list, dst_db):
         """Content dispatcher."""
 
         # add events to per-table caches
diff --git a/scripts/cube_dispatcher.py b/scripts/cube_dispatcher.py
index d59ac300..7425ae7f 100755
--- a/scripts/cube_dispatcher.py
+++ b/scripts/cube_dispatcher.py
@@ -39,7 +39,7 @@ class CubeDispatcher(pgq.SerialConsumer):
         src_db.commit()
         return curs.fetchone()[0]
 
-    def process_remote_batch(self, batch_id, ev_list, dst_db):
+    def process_remote_batch(self, src_db, batch_id, ev_list, dst_db):
         
         # actual processing
         date_str = self.get_part_date(batch_id)
diff --git a/scripts/table_dispatcher.py b/scripts/table_dispatcher.py
index 054ced9a..32d26f2c 100755
--- a/scripts/table_dispatcher.py
+++ b/scripts/table_dispatcher.py
@@ -30,7 +30,7 @@ class TableDispatcher(pgq.SerialConsumer):
                 else:
                     self.field_map[tmp[0]] = tmp[1]
 
-    def process_remote_batch(self, batch_id, ev_list, dst_db):
+    def process_remote_batch(self, src_db, batch_id, ev_list, dst_db):
         if len(ev_list) == 0:
             return