Method _dump_pipeline_file

dvc/dvcfile.py:291–315

(self, stages)

            raise ParametrizedDumpError(f"cannot {action} a parametrized {stage}")

    def _dump_pipeline_file(self, stages):
        stages = stages if isinstance(stages, list) else [stages]
        if not stages:
            return

        for stage in stages:
            self._check_if_parametrized(stage)

        with modify_yaml(self.path, fs=self.repo.fs) as data:
            if not data:
                logger.info("Creating '%s'", self.relpath)

            data["stages"] = data.get("stages", {})
            for stage in stages:
                stage_data = serialize.to_pipeline_file(stage)
                existing_entry = stage.name in data["stages"]
                action = "Modifying" if existing_entry else "Adding"
                logger.info("%s stage '%s' in '%s'", action, stage.name, self.relpath)
                if existing_entry:
                    orig_stage_data = data["stages"][stage.name]
                    apply_diff(stage_data[stage.name], orig_stage_data)
                else:
                    data["stages"].update(stage_data)

        self.repo.scm_context.track_file(self.relpath)

    @property
    def stage(self):