From 406e71edad887afab5c76e12f45202b149f0a237 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Tue, 17 Feb 2009 13:16:27 +0200 Subject: [PATCH] plainworker: process_remote_event takes cursors not dbs --- tests/cascade/plainworker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/cascade/plainworker.py b/tests/cascade/plainworker.py index 48f00530..9a8c165c 100755 --- 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() -- 2.39.5