fix: expect_sync to londiste.local_add_table i_trg_args

diff --git a/python/londiste/setup.py b/python/londiste/setup.py
index d7423406033050be9ad9923a5996e0ea0814cc3f..1bfd703925173141376f5aa5206ad55004a38568 100644 (file)
--- a/python/londiste/setup.py
+++ b/python/londiste/setup.py
@@ -180,14 +180,14 @@ class LondisteSetup(CascadeAdmin):
             attrs['handler'] = hstr
             p.add(tgargs)
 
+        if self.options.expect_sync:
+            tgargs.append('expect_sync')
+
         # actual table registration
         q = "select * from londiste.local_add_table(%s, %s, %s)"
         self.exec_cmd(dst_curs, q, [self.set_name, tbl, tgargs])
 
-        if self.options.expect_sync:
-            q = "select * from londiste.local_set_table_state(%s, %s, NULL, 'ok')"
-            self.exec_cmd(dst_curs, q, [self.set_name, tbl])
-        else:
+        if not self.options.expect_sync:
             if self.options.skip_truncate:
                 attrs['skip_truncate'] = 1
             if self.options.copy_condition: