repo: drop active_stages

This commit is contained in:
pawel
2019-08-27 13:46:29 +02:00
parent 16b62d154a
commit babd5b2a12
+4 -24
View File
@@ -225,8 +225,6 @@ class Repo(object):
stages.extend(
self.collect(target, with_deps=with_deps)
)
elif active:
stages = self.active_stages()
else:
stages = self.stages()
@@ -353,25 +351,15 @@ class Repo(object):
return G, G_active
@staticmethod
def _pipelines(graph):
def pipelines(self, from_directory=None):
import networkx as nx
G, G_active = self.graph(from_directory=from_directory)
return [
graph.subgraph(c).copy()
for c in nx.weakly_connected_components(graph)
G.subgraph(c).copy() for c in nx.weakly_connected_components(G)
]
def pipelines(self, from_directory=None):
G, _ = self.graph(from_directory=from_directory)
return self._pipelines(G)
def pipelines_for_active_nodes(self, from_directory=None):
_, G_active = self.graph(from_directory=from_directory)
return self._pipelines(G_active)
@staticmethod
def _filter_out_dirs(dirs, outs, root_dir):
def filter_dirs(dname):
@@ -423,14 +411,6 @@ class Repo(object):
return stages
def active_stages(self, from_directory=None):
import networkx as nx
stages = []
for G in self.pipelines_for_active_nodes(from_directory):
stages.extend(list(nx.get_node_attributes(G, "stage").values()))
return stages
def find_outs_by_path(self, path, outs=None, recursive=False):
if not outs:
# there is no `from_directory=path` argument because some data