summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorMarko Kreen2014-07-22 18:49:27 +0000
committerMarko Kreen2014-07-22 18:49:27 +0000
commit063920caa6d38aa45e28f9aa7d026cc0acdac256 (patch)
tree322cca8ce63b95633ab216bfd022a65a66de3403 /python
parent0072a32cdcf49aef83cf56285d320dfe554fd0d5 (diff)
parent96031dcb0204de5ec606cc43606eedecfd69c6ee (diff)
Merge pull request #37 from mrrusof/fix-execute-skip
Fix execute skip
Diffstat (limited to 'python')
-rw-r--r--python/londiste/playback.py2
-rw-r--r--python/londiste/setup.py2
2 files changed, 2 insertions, 2 deletions
diff --git a/python/londiste/playback.py b/python/londiste/playback.py
index f21d7e58..c15a3f5b 100644
--- a/python/londiste/playback.py
+++ b/python/londiste/playback.py
@@ -726,7 +726,7 @@ class Replicator(CascadedWorker):
res = self.exec_cmd(dst_curs, q, [self.queue_name, fname, sql, s_attrs], commit = False)
ret = res[0]['ret_code']
if ret > 200:
- self.log.info("Skipping execution of '%s'", fname)
+ self.log.warning("Skipping execution of '%s'", fname)
if pgver >= 80300:
dst_curs.execute("set local session_replication_role = 'replica'")
return
diff --git a/python/londiste/setup.py b/python/londiste/setup.py
index 055be922..d374d92e 100644
--- a/python/londiste/setup.py
+++ b/python/londiste/setup.py
@@ -572,7 +572,7 @@ class LondisteSetup(CascadeAdmin):
q = "select * from londiste.execute_start(%s, %s, %s, true, %s)"
res = self.exec_cmd(db, q, [self.queue_name, fname, sql, attrs.to_urlenc()], commit = False)
ret = res[0]['ret_code']
- if ret >= 300:
+ if ret > 200:
self.log.warning("Skipping execution of '%s'", fname)
continue
if attrs.need_execute(curs, local_tables, local_seqs):