Skip to content

Commit

Permalink
Remove writing of expanded pipeline
Browse files Browse the repository at this point in the history
That option does not exist.
  • Loading branch information
timj committed Aug 8, 2024
1 parent f36ff51 commit 4ce05f7
Showing 1 changed file with 1 addition and 18 deletions.
19 changes: 1 addition & 18 deletions python/lsst/pipe/base/pipeline_doc_builder.py
Original file line number Diff line number Diff line change
Expand Up @@ -376,7 +376,7 @@ def from_dirs(
def __call__(self, task_defs: Sequence[TaskDef] | None = None) -> None:
if task_defs is None:
task_defs = list(self.pipeline)
self.write_expanded_pipeline(task_defs)
self.pipeline.write_to_uri(self.yaml_path.parent)
self.write_dot(task_defs)
self.write_rst(task_defs)

Expand Down Expand Up @@ -406,23 +406,6 @@ def iter_graph_dot_paths(self) -> Iterator[tuple[Path, Path]]:
for task_paths in self.tasks.values():
yield (task_paths.graph_path, task_paths.dot_path)

def write_expanded_pipeline(self, task_defs: Sequence[TaskDef] | None = None) -> None:
"""Write the expanded pipeline.
This just calls `Pipeline.write_to_uri` with ``expand=True``.
Parameters
----------
task_defs : `Sequence` [ `TaskDef` ], optional
The result of a call to `Pipeline.toExpandedPipeline`, captured in
a sequence. May be `None` (default) to expand internally; provided
as a way for calling code to only expand the pipeline once.
"""
if task_defs is None:
task_defs = list(self.pipeline)
self.yaml_path.parent.mkdir(parents=True, exist_ok=True)
self.pipeline.write_to_uri(self.yaml_path.parent, expand=True, task_defs=task_defs)

def write_dot(self, task_defs: Sequence[TaskDef] | None = None) -> None:
"""Write the GraphViz DOT representations of the pipeline and its
tasks.
Expand Down

0 comments on commit 4ce05f7

Please sign in to comment.