def reset_last_sync(cls): transaction.begin() DBSession.query(cls) \ .filter(cls.validated) \ .update({'last_sync': base_time()}) transaction.commit()