diff options
Diffstat (limited to 'python')
-rw-r--r-- | python/londiste/playback.py | 9 | ||||
-rw-r--r-- | python/londiste/table_copy.py | 2 |
2 files changed, 7 insertions, 4 deletions
diff --git a/python/londiste/playback.py b/python/londiste/playback.py index d9db6fd1..ea55975a 100644 --- a/python/londiste/playback.py +++ b/python/londiste/playback.py @@ -66,7 +66,7 @@ class TableState(object): self.sync_tick_id = None self.ok_batch_count = 0 self.last_tick = 0 - self.skip_truncate = False + self.table_attrs = {} self.copy_role = None self.dropped_ddl = None # except this @@ -81,7 +81,7 @@ class TableState(object): self.sync_tick_id = None self.ok_batch_count = 0 self.last_tick = 0 - self.skip_truncate = False + self.table_attrs = {} self.changed = 1 def change_snapshot(self, str_snapshot, tag_changed = 1): @@ -162,7 +162,10 @@ class TableState(object): self.change_snapshot(row['custom_snapshot'], 0) self.state = self.parse_state(row['merge_state']) self.changed = 0 - self.skip_truncate = row['skip_truncate'] + if row['table_attrs']: + self.table_attrs = skytools.db_urldecode(row['table_attrs']) + else: + self.table_attrs = {} self.copy_role = row['copy_role'] self.dropped_ddl = row['dropped_ddl'] if row['merge_state'] == "?": diff --git a/python/londiste/table_copy.py b/python/londiste/table_copy.py index d90e00ae..75d92f56 100644 --- a/python/londiste/table_copy.py +++ b/python/londiste/table_copy.py @@ -121,7 +121,7 @@ class CopyTable(Replicator): dst_struct.drop(dst_curs, objs, log = self.log) # drop data - if tbl_stat.skip_truncate: + if tbl_stat.table_attrs.get('skip_truncate'): self.log.info("%s: skipping truncate" % tbl_stat.name) else: self.log.info("%s: truncating" % tbl_stat.name) |