diff options
| author | Marko Kreen | 2010-12-03 12:14:08 +0000 |
|---|---|---|
| committer | Marko Kreen | 2010-12-03 12:14:08 +0000 |
| commit | 65866afaa77f02c628cd1a3fbdf185fb161b1260 (patch) | |
| tree | 923fdf8fd4848786ff85f872d30041fd0cf004d3 /python | |
| parent | 71fa7019da111d9534969d25e7fdf57a30d7935f (diff) | |
londiste playback: fix cursor name
Diffstat (limited to 'python')
| -rw-r--r-- | python/londiste/playback.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/londiste/playback.py b/python/londiste/playback.py index bdb5dcda..dd2772a2 100644 --- a/python/londiste/playback.py +++ b/python/londiste/playback.py @@ -565,7 +565,7 @@ class Replicator(CascadedWorker): # fixme: curs? pgver = dst_curs.connection.server_version if pgver >= 80300: - curs.execute("set local session_replication_role = 'local'") + dst_curs.execute("set local session_replication_role = 'local'") q = "select * from londiste.execute_start(%s, %s, %s, false)" res = self.exec_cmd(dst_curs, q, [self.queue_name, fname, sql], commit = False) ret = res[0]['ret_code'] @@ -577,7 +577,7 @@ class Replicator(CascadedWorker): q = "select * from londiste.execute_finish(%s, %s)" self.exec_cmd(dst_curs, q, [self.queue_name, fname], commit = False) if pgver >= 80300: - curs.execute("set local session_replication_role = 'replica'") + dst_curs.execute("set local session_replication_role = 'replica'") def apply_sql(self, sql, dst_curs): |