(self, dst_db)
Remove unnecessary snapshot info from tables.
Remove unnecessary snapshot info from tables.
Remove unnecessary snapshot info from tables .
def copy_snapshot_cleanup(self, dst_db):
        """Remove unnecessary snapshot info from tables."""
        no_lag = not self.work_state
        changes = False
        for t in self.table_list:
            t.gc_snapshot(self.copy_thread, self.prev_tick, self.cur_tick, no_lag)
            if t.changed:
                changes = True

        if changes:
            self.save_table_state(dst_db.cursor())
            dst_db.commit()
def copy_snapshot_cleanup ( self , dst_db ) : no_lag = not self . work_state changes = False for t in self . table_list : t . gc_snapshot ( self . copy_thread , self . prev_tick , self . cur_tick , no_lag ) if t . changed : changes = True if changes : self . save_table_state ( dst_db . cursor ( ) ) dst_db . commit ( )