plainworker: process_remote_event takes cursors not dbs

diff --git a/tests/cascade/plainworker.py b/tests/cascade/plainworker.py
index 48f00530b83116ff886641f72f6bab138088742c..9a8c165c57f13533f90f0c8bcc288868b8a432b3 100755 (executable)
--- a/tests/cascade/plainworker.py
+++ b/tests/cascade/plainworker.py
@@ -5,7 +5,7 @@ import sys, time, skytools
 from pgq.cascade.worker import CascadedWorker
 
 class PlainCascadedWorker(CascadedWorker):
-    def process_remote_event(self, src_db, dst_db, ev):
+    def process_remote_event(self, src_curs, dst_curs, ev):
         self.log.info("got events: %s / %s" % (ev.ev_type, ev.ev_data))
         ev.tag_done()