

def __init__(self, source_db, target_db, doc_types, max_changes_before_commit=100, max_time_before_commit=datetime.timedelta(seconds=5)):
    self.source_db = source_db
    self.target_db = target_db
    self.doc_types = doc_types
    self.max_changes_before_commit = max_changes_before_commit
    self.max_time_before_commit = max_time_before_commit
    self._ids_to_save = None
    self._ids_to_delete = None
    self._reset()

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