def METHOD_NAME(self, dburl, num_records, current_batch_num):
    old_continuation_file = self.get_old_continuation_file()
    if old_continuation_file:
        # reopen to ensure file pointer is at starting point
        old_continuation_file = open(old_continuation_file, "r")
    with self.open_new_continuation_file() as new_continuation_file:
        METHOD_NAME(
            yaml_file=self.yaml_file,
            user_options=self.vars,
            target_number=self.stopping_criteria,
            continuation_file=old_continuation_file,
            generate_continuation_file=new_continuation_file,
            generate_cci_mapping_file=self.generate_mapping_file,
            dburl=dburl,
            load_declarations=self.loading_rules,
            should_create_cci_record_type_tables=True,
            plugin_options={
                "org_config": self.org_config,
                "project_config": self.project_config,
                **self.plugin_options,
            },
        )
    if (
        new_continuation_file
        and Path(new_continuation_file.name).exists()
        and self.working_directory
    ):
        shutil.move(
            new_continuation_file.name, self.default_continuation_file_path()
        )