def run(self): self.initialize() tags = pd.read_sql_query("SELECT * FROM TAGS", self.con) self.collect_changes(tags) self.apply_changes_if_not_dry() self.close()