refactor: enable build_graph to be invoked from the service (#1543)

Author: jsam

renku/cli/log.py

@@ -83,11 +83,9 @@
 """
 
 import click
-from git import NULL_TREE
 
-from renku.core.commands.client import pass_local_client
 from renku.core.commands.format.graph import FORMATS
-from renku.core.commands.graph import Graph
+from renku.core.commands.graph import build_graph
 
 
 @click.command()
@@ -96,24 +94,7 @@
 @click.option("--no-output", is_flag=True, default=False, help="Display commands without output files.")
 @click.option("--strict", is_flag=True, default=False, help="Validate triples before output.")
 @click.argument("paths", type=click.Path(exists=False), nargs=-1)
-@pass_local_client(requires_migration=True)
-def log(client, revision, format, no_output, strict, paths):
+def log(revision, format, no_output, strict, paths):
     """Show logs for a file."""
-    graph = Graph(client)
-    if not paths:
-        start, is_range, stop = revision.partition("..")
-        if not is_range:
-            stop = start
-        elif not stop:
-            stop = "HEAD"
-
-        commit = client.repo.rev_parse(stop)
-        paths = (
-            str(client.path / item.a_path)
-            for item in commit.diff(commit.parents or NULL_TREE)
-            # if not item.deleted_file
-        )
-
-    # NOTE shall we warn when "not no_output and not paths"?
-    graph.build(paths=paths, revision=revision, can_be_cwl=no_output)
+    graph = build_graph(revision, no_output, paths)
     FORMATS[format](graph, strict=strict)

renku/core/commands/graph.py

@@ -22,8 +22,10 @@
 from pathlib import Path
 
 import attr
+from git import NULL_TREE
 
 from renku.core import errors
+from renku.core.commands.client import pass_local_client
 from renku.core.models.entities import Collection, Entity
 from renku.core.models.git import Range
 from renku.core.models.provenance.activities import Activity, ProcessRun, Usage, WorkflowRun
@@ -510,3 +512,26 @@ def workflow_has_identical_subprocesses(workflow_, subprocesses_ids_):
                     return workflow.association.plan
 
         return run
+
+
+@pass_local_client(requires_migration=True)
+def build_graph(client, revision, no_output, paths):
+    """Build graph structure."""
+    graph = Graph(client)
+    if not paths:
+        start, is_range, stop = revision.partition("..")
+        if not is_range:
+            stop = start
+        elif not stop:
+            stop = "HEAD"
+
+        commit = client.repo.rev_parse(stop)
+        paths = (
+            str(client.path / item.a_path)
+            for item in commit.diff(commit.parents or NULL_TREE)
+            # if not item.deleted_file
+        )
+
+    # NOTE shall we warn when "not no_output and not paths"?
+    graph.build(paths=paths, revision=revision, can_be_cwl=no_output)
+    return graph