From b95d6f2e92220e2f60b9dad0f63f2954e7066032 Mon Sep 17 00:00:00 2001 From: Ruslan Kuprieiev Date: Tue, 6 Feb 2018 13:29:06 +0200 Subject: [PATCH] dvc: remove unused Pipeline class Signed-off-by: Ruslan Kuprieiev --- dvc/project.py | 31 ------------------------------- 1 file changed, 31 deletions(-) diff --git a/dvc/project.py b/dvc/project.py index 148559c5e..736a833bc 100644 --- a/dvc/project.py +++ b/dvc/project.py @@ -34,37 +34,6 @@ class ReproductionError(DvcException): super(ReproductionError, self).__init__(u'Failed to reproduce \'{}\': {}'.format(dvc_file_name, msg)) -class Pipeline(object): - - def __init__(self, project, G): - self.project = project - self.G = G - - def graph(self): - return self.G - - def stages(self): - return nx.get_node_attributes(self.G, 'stage') - - def changed(self, stage): - for node in nx.dfs_postorder_nodes(G, stage.path.relative_to(self.project.root_dir)): - if self.stages[node].changed(): - return True - return False - - def reproduce(self, stage): - if stage not in self.stages(): - raise StageNotInPipelineError() - - if not self.changed(stage): - raise PipelineNotChangedError() - - for node in nx.dfs_postorder_nodes(G, stage.path.relative_to(self.project.root_dir)): - self.stages[node].reproduce() - - stage.reproduce() - - class Project(object): DVC_DIR = '.dvc'