@@ -376,7 +376,7 @@ def from_dirs(
376376 def __call__ (self , task_defs : Sequence [TaskDef ] | None = None ) -> None :
377377 if task_defs is None :
378378 task_defs = list (self .pipeline )
379- self .write_expanded_pipeline ( task_defs )
379+ self .pipeline . write_to_uri ( self . yaml_path . parent )
380380 self .write_dot (task_defs )
381381 self .write_rst (task_defs )
382382
@@ -406,23 +406,6 @@ def iter_graph_dot_paths(self) -> Iterator[tuple[Path, Path]]:
406406 for task_paths in self .tasks .values ():
407407 yield (task_paths .graph_path , task_paths .dot_path )
408408
409- def write_expanded_pipeline (self , task_defs : Sequence [TaskDef ] | None = None ) -> None :
410- """Write the expanded pipeline.
411-
412- This just calls `Pipeline.write_to_uri` with ``expand=True``.
413-
414- Parameters
415- ----------
416- task_defs : `Sequence` [ `TaskDef` ], optional
417- The result of a call to `Pipeline.toExpandedPipeline`, captured in
418- a sequence. May be `None` (default) to expand internally; provided
419- as a way for calling code to only expand the pipeline once.
420- """
421- if task_defs is None :
422- task_defs = list (self .pipeline )
423- self .yaml_path .parent .mkdir (parents = True , exist_ok = True )
424- self .pipeline .write_to_uri (self .yaml_path .parent , expand = True , task_defs = task_defs )
425-
426409 def write_dot (self , task_defs : Sequence [TaskDef ] | None = None ) -> None :
427410 """Write the GraphViz DOT representations of the pipeline and its
428411 tasks.
0 commit comments