@@ -164,14 +164,6 @@ def build_pipe_cmd(
164164 help = "Override config: include or exclude full serialized data in graphs (requires --graph)" ,
165165 ),
166166 ] = None ,
167- library_dir : Annotated [
168- list [str ] | None ,
169- typer .Option (
170- "--library-dir" ,
171- "-L" ,
172- help = "Directory to search for pipe definitions (.plx files). Can be specified multiple times." ,
173- ),
174- ] = None ,
175167) -> None :
176168 make_pipelex_for_cli (context = ErrorContext .VALIDATION_BEFORE_BUILD_PIPE )
177169
@@ -302,6 +294,8 @@ async def run_pipeline():
302294 save_text_to_path (text = "" , path = init_path )
303295 typer .secho (f"✅ Package init file saved to: { init_path } " , fg = typer .colors .GREEN )
304296
297+ get_report_delegate ().generate_report ()
298+
305299 # Generate graphs if it was tracked during the build process
306300 if builder_graph_spec :
307301 typer .secho ("\n 📊 Generating graphs..." , fg = typer .colors .CYAN )
@@ -322,11 +316,13 @@ async def run_pipeline():
322316 try :
323317 built_pipe_execution_config = execution_config .with_graph_config_overrides (mock_inputs = True )
324318
319+ # pass empty library_dirs to avoid loading any libraries set at env var or instance level:
320+ # we don't want any other pipeline to interfere with the pipeline we just built
325321 built_pipe_output = await execute_pipeline (
326322 plx_content = plx_content ,
327323 pipe_run_mode = PipeRunMode .DRY ,
328324 execution_config = built_pipe_execution_config ,
329- library_dirs = library_dir ,
325+ library_dirs = [] ,
330326 )
331327 if built_pipe_output .graph_spec :
332328 pipeline_graph_dir = graphs_dir / "pipeline_graph"
@@ -339,7 +335,7 @@ async def run_pipeline():
339335 )
340336 if pipeline_graph_count > 0 :
341337 typer .secho (
342- f"📊 { pipeline_graph_count } pipeline graph outputs saved to: { pipeline_graph_dir } " ,
338+ f"📊 { pipeline_graph_count } built pipeline graph outputs saved to: { pipeline_graph_dir } " ,
343339 fg = typer .colors .CYAN ,
344340 )
345341 except Exception as graph_exc :
@@ -348,8 +344,6 @@ async def run_pipeline():
348344 end_time = time .time ()
349345 typer .secho (f"\n ✅ Pipeline built in { end_time - start_time :.2f} seconds\n " , fg = typer .colors .WHITE )
350346
351- get_report_delegate ().generate_report ()
352-
353347 # Show how to run the pipe
354348 console = get_console ()
355349 console .print ("\n 📋 [cyan]To run your pipeline:[/cyan]" )
0 commit comments