From 2439d6cf51a45f4945e20e424dfe1b30dd08918e Mon Sep 17 00:00:00 2001 From: Ruslan Kuprieiev Date: Sun, 3 May 2020 23:23:19 +0300 Subject: [PATCH] dvc.yaml: rename stages -> pipeline --- dvc/dvcfile.py | 10 +++++----- dvc/schema.py | 4 ++-- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/dvc/dvcfile.py b/dvc/dvcfile.py index 64a74eac01..dacf332257 100644 --- a/dvc/dvcfile.py +++ b/dvc/dvcfile.py @@ -197,13 +197,13 @@ def _dump_pipeline_file(self, stage): else: open(self.path, "w+").close() - data["stages"] = data.get("stages", {}) + data["pipeline"] = data.get("pipeline", {}) stage_data = serialize.to_pipeline_file(stage) - if data["stages"].get(stage.name): - orig_stage_data = data["stages"][stage.name] + if data["pipeline"].get(stage.name): + orig_stage_data = data["pipeline"][stage.name] apply_diff(stage_data[stage.name], orig_stage_data) else: - data["stages"].update(stage_data) + data["pipeline"].update(stage_data) dump_stage_file(self.path, data) self.repo.scm.track_file(relpath(self.path)) @@ -218,7 +218,7 @@ def stage(self): def stages(self): data, _ = self._load() lockfile_data = self._lockfile.load() - return StageLoader(self, data.get("stages", {}), lockfile_data) + return StageLoader(self, data.get("pipeline", {}), lockfile_data) def remove(self, force=False): if not force: diff --git a/dvc/schema.py b/dvc/schema.py index 4e06197873..61ed0f93aa 100644 --- a/dvc/schema.py +++ b/dvc/schema.py @@ -5,7 +5,7 @@ from voluptuous import Any, Schema, Optional, Required -STAGES = "stages" +PIPELINE = "pipeline" SINGLE_STAGE_SCHEMA = { StageParams.PARAM_MD5: output.CHECKSUM_SCHEMA, StageParams.PARAM_CMD: Any(str, None), @@ -38,7 +38,7 @@ **{Optional(p.value): [str] for p in OutputParams}, } } -MULTI_STAGE_SCHEMA = {STAGES: SINGLE_PIPELINE_STAGE_SCHEMA} +MULTI_STAGE_SCHEMA = {PIPELINE: SINGLE_PIPELINE_STAGE_SCHEMA} COMPILED_SINGLE_STAGE_SCHEMA = Schema(SINGLE_STAGE_SCHEMA) COMPILED_MULTI_STAGE_SCHEMA = Schema(MULTI_STAGE_SCHEMA)