

def commit(self):
    ids_to_save = filter_doc_ids_by_doc_type(self.source_db, self._ids_to_save, self.doc_types)
    copy_docs(self.source_db, self.target_db, ids_to_save)
    delete_docs(self.target_db, self._ids_to_delete)
    self._reset()

dataset/ETHPy150Open dimagi/commcare-hq/corehq/doctypemigrations/continuous_migrate.py ContinuousReplicator.commit/original