Merge pull request #754 from Pipelex/release/v0.20.7

lchoquel · web-flow · commit 1f1ed65ff4f1 · 2026-03-13T11:08:02.000+01:00
- Bump `mthds` dependency to `&gt;=0.1.1`.
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -93,24 +93,26 @@
             "justMyCode": false
         },
         {
-            "name": "Debug run pipe bundle no inputs",
+            "name": "Debug run bundle no inputs",
             "type": "debugpy",
             "request": "launch",
             "program": "${workspaceFolder}/.venv/bin/pipelex",
             "args": [
                 "run",
+                "bundle",
                 "tests/integration/pipelex/pipes/pipelines/test_image_out_in.mthds",
             ],
             "console": "integratedTerminal",
             "justMyCode": false
         },
         {
-            "name": "Debug run pipe bundle with inputs",
+            "name": "Debug run pipe from bundle with inputs",
             "type": "debugpy",
             "request": "launch",
             "program": "${workspaceFolder}/.venv/bin/pipelex",
             "args": [
                 "run",
+                "bundle",
                 "tests/integration/pipelex/pipes/pipelines/test_image_out_in.mthds",
                 "--pipe",
                 "describe_image",
@@ -127,6 +129,7 @@
             "program": "${workspaceFolder}/.venv/bin/pipelex",
             "args": [
                 "run",
+                "pipe",
                 "write_discord_newsletter",
                 "--inputs",
                 "tests/data/discord_newsletter/discord_sample_input.json",
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,6 +1,8 @@
 # Changelog
 
-## [Unreleased]
+## [v0.20.7] - 2026-03-12
+
+- Bump `mthds` dependency to `>=0.1.1`.
 
 ## [v0.20.6] - 2026-03-12
 
diff --git a/pipelex/cli/agent_cli/commands/inputs/bundle_cmd.py b/pipelex/cli/agent_cli/commands/inputs/bundle_cmd.py
@@ -84,7 +84,7 @@ def inputs_bundle_cmd(
 
     pipe_code: str | None = pipe
     library_dirs = [Path(lib_dir) for lib_dir in library_dir] if library_dir else None
-    make_pipelex_for_agent_cli(library_dirs=library_dirs, log_level=ctx.obj["log_level"], needs_inference=False)
+    make_pipelex_for_agent_cli(library_dirs=library_dirs, log_level=ctx.obj["log_level"], needs_inference=False, needs_model_specs=True)
 
     try:
         result = asyncio.run(inputs_core(pipe_code=pipe_code, bundle_path=Path(bundle_path), library_dirs=library_dirs))  # type: ignore[arg-type]
diff --git a/pipelex/cli/agent_cli/commands/inputs/method_cmd.py b/pipelex/cli/agent_cli/commands/inputs/method_cmd.py
@@ -56,7 +56,7 @@ def inputs_method_cmd(
     if library_dir:
         library_dirs_paths.extend(Path(lib_dir) for lib_dir in library_dir)
 
-    make_pipelex_for_agent_cli(library_dirs=library_dirs_paths, log_level=ctx.obj["log_level"], needs_inference=False)
+    make_pipelex_for_agent_cli(library_dirs=library_dirs_paths, log_level=ctx.obj["log_level"], needs_inference=False, needs_model_specs=True)
 
     try:
         result = asyncio.run(inputs_core(pipe_code=pipe_code, bundle_path=bundle_path, library_dirs=library_dirs_paths))
diff --git a/pipelex/cli/agent_cli/commands/inputs/pipe_cmd.py b/pipelex/cli/agent_cli/commands/inputs/pipe_cmd.py
@@ -64,7 +64,7 @@ def inputs_pipe_cmd(
             library_dir = [*export_dirs, *library_dir]
 
     library_dirs = [Path(lib_dir) for lib_dir in library_dir] if library_dir else None
-    make_pipelex_for_agent_cli(library_dirs=library_dirs, log_level=ctx.obj["log_level"], needs_inference=False)
+    make_pipelex_for_agent_cli(library_dirs=library_dirs, log_level=ctx.obj["log_level"], needs_inference=False, needs_model_specs=True)
 
     try:
         result = asyncio.run(inputs_core(pipe_code=pipe_code, bundle_path=None, library_dirs=library_dirs))
diff --git a/pipelex/cli/commands/build/inputs/_inputs_core.py b/pipelex/cli/commands/build/inputs/_inputs_core.py
@@ -116,7 +116,9 @@ def execute_generate_inputs(
     telemetry_command_label: str = f"{COMMAND} {SUB_COMMAND_INPUTS}",
 ) -> None:
     """Synchronous entry point wrapping the async inputs generation with Pipelex setup/teardown."""
-    pipelex_instance = make_pipelex_for_cli(context=ErrorContext.VALIDATION_BEFORE_BUILD_INPUTS, library_dirs=library_dir, needs_inference=False)
+    pipelex_instance = make_pipelex_for_cli(
+        context=ErrorContext.VALIDATION_BEFORE_BUILD_INPUTS, library_dirs=library_dir, needs_inference=False, needs_model_specs=True
+    )
 
     try:
         with get_telemetry_manager().telemetry_context():
diff --git a/pipelex/cli/commands/build/output/_output_core.py b/pipelex/cli/commands/build/output/_output_core.py
@@ -131,7 +131,9 @@ def execute_generate_output(
     telemetry_command_label: str = f"{COMMAND} {SUB_COMMAND_OUTPUT}",
 ) -> None:
     """Synchronous entry point wrapping the async output generation with Pipelex setup/teardown."""
-    pipelex_instance = make_pipelex_for_cli(context=ErrorContext.VALIDATION_BEFORE_BUILD_OUTPUT, library_dirs=library_dir, needs_inference=False)
+    pipelex_instance = make_pipelex_for_cli(
+        context=ErrorContext.VALIDATION_BEFORE_BUILD_OUTPUT, library_dirs=library_dir, needs_inference=False, needs_model_specs=True
+    )
 
     try:
         with get_telemetry_manager().telemetry_context():
diff --git a/pipelex/cli/commands/run/_run_core.py b/pipelex/cli/commands/run/_run_core.py
@@ -137,9 +137,9 @@ async def _execute_run(
         raise typer.Exit(1) from exc
 
     # Pretty print main_stuff unless disabled or in dry run mode
-    if not no_pretty_print and not dry_run:
+    if not no_pretty_print and not dry_run and (main_stuff := pipe_output.optional_main_stuff):
         title = f"Final output of pipe [red]{pipe_code}[/red]"
-        pipe_output.main_stuff.pretty_print_stuff(title=title)
+        main_stuff.pretty_print_stuff(title=title)
 
     # Determine if we need an output directory
     output_path: Path | None = None
diff --git a/pipelex/cli/commands/show_cmd.py b/pipelex/cli/commands/show_cmd.py
@@ -230,7 +230,7 @@ def show_pipe_cmd(
         raise typer.Exit(1)
 
     library_dirs = [Path(lib_dir) for lib_dir in library_dir] if library_dir else None
-    make_pipelex_for_cli(context=ErrorContext.VALIDATION_BEFORE_SHOW_PIPE, library_dirs=library_dirs, needs_inference=False)
+    make_pipelex_for_cli(context=ErrorContext.VALIDATION_BEFORE_SHOW_PIPE, library_dirs=library_dirs, needs_inference=False, needs_model_specs=True)
 
     try:
         library_manager = get_library_manager()
diff --git a/pipelex/cli/commands/which_cmd.py b/pipelex/cli/commands/which_cmd.py
@@ -82,7 +82,7 @@ def which_cmd(
         pipelex which my_domain.my_pipe -L ./my_pipes
         PIPELEXPATH=/path/to/pipes pipelex which some_pipe
     """
-    make_pipelex_for_cli(context=ErrorContext.VALIDATION_BEFORE_SHOW_PIPE, needs_inference=False)
+    make_pipelex_for_cli(context=ErrorContext.VALIDATION_BEFORE_SHOW_PIPE, needs_inference=False, needs_model_specs=True)
 
     try:
         library_manager = get_library_manager()
diff --git a/pipelex/core/pipes/pipe_output.py b/pipelex/core/pipes/pipe_output.py
@@ -26,6 +26,10 @@ class PipeOutput(PipeOutputAbstract[WorkingMemory]):
     def main_stuff(self) -> Stuff:
         return self.working_memory.get_main_stuff()
 
+    @property
+    def optional_main_stuff(self) -> Stuff | None:
+        return self.working_memory.get_optional_main_stuff()
+
     def main_stuff_as_list(self, item_type: type[StuffContentType]) -> ListContent[StuffContentType]:
         """Get main stuff content as ListContent with items of type StuffContentType.
         If the items are of possibly various types, use item_type=StuffContent.
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "pipelex"
-version = "0.20.6"
+version = "0.20.7"
 description = "Execute composable AI methods declared in the MTHDS open standard"
 authors = [{ name = "Evotis S.A.S.", email = "oss@pipelex.com" }]
 maintainers = [{ name = "Pipelex staff", email = "oss@pipelex.com" }]
@@ -28,7 +28,7 @@ dependencies = [
   "json2html>=1.3.0",
   "kajson==0.3.1",
   "markdown>=3.6",
-  "mthds>=0.1.0",
+  "mthds>=0.1.1",
   "networkx>=3.4.2",
   "openai>=1.108.1",
   "opentelemetry-api",
diff --git a/uv.lock b/uv.lock
