Merge pull request #243 from Pipelex/release/v0.8.1

Release/v0.8.1

Author: thomashebrard

CHANGELOG.md

@@ -1,5 +1,11 @@
 # Changelog
 
+## [v0.8.1] - 2025-08-27
+
+### Bugfix
+
+- Bugfix: Fixed the `PipeFunc` output concept code and structure class name in the dry run.
+
 ## [v0.8.0] - 2025-08-27
 
 ### Refactor

pipelex/pipe_operators/func/pipe_func.py

@@ -113,10 +113,10 @@ async def _dry_run_operator_pipe(
                 requirement = TypedNamedInputRequirement(
                     variable_name="mock_output",
                     concept=ConceptFactory.make(
-                        concept_code=f"{return_type.__name__}",
+                        concept_code=self.output.code,
                         domain="generic",
                         definition="Lorem Ipsum",
-                        structure_class_name=return_type.__name__,
+                        structure_class_name=self.output.structure_class_name,
                     ),
                     structure_class=return_type,
                     multiplicity=False,

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "pipelex"
-version = "0.8.0"
+version = "0.8.1"
 description = "Pipelex is an open-source dev tool based on a simple declarative language that lets you define replicable, structured, composable LLM pipelines."
 authors = [{ name = "Evotis S.A.S.", email = "evotis@pipelex.com" }]
 maintainers = [{ name = "Pipelex staff", email = "oss@pipelex.com" }]

tests/test_pipelines/test.toml

@@ -0,0 +1,10 @@
+
+domain = "test"
+
+[pipe.read_doc_file]
+type = "PipeFunc"
+definition = "Read the content of related codebase files"
+inputs = { related_file_paths = "FilePath" }
+output = "CodebaseFileContent"
+function_name = "read_file_content"
+

tests/test_pipelines/test_file_func_registry.py

@@ -0,0 +1,49 @@
+from typing import List
+
+from pydantic import Field
+
+from pipelex.core.memory.working_memory import WorkingMemory
+from pipelex.core.stuffs.stuff_content import ListContent, StructuredContent
+from pipelex.tools.func_registry import func_registry
+
+
+class FilePath(StructuredContent):
+    """A path to a file in the codebase."""
+
+    path: str = Field(description="Path to the file")
+
+
+class CodebaseFileContent(StructuredContent):
+    """Content of a codebase file."""
+
+    file_path: str = Field(description="Path to the codebase file")
+    file_content: str = Field(description="Content of the codebase file")
+
+
+def read_file_content(working_memory: WorkingMemory) -> ListContent[CodebaseFileContent]:
+    """Read the content of related codebase files.
+
+    Args:
+        working_memory: Working memory containing related_file_paths
+
+    Returns:
+        ListContent of CodebaseFileContent objects
+    """
+
+    file_paths_list = working_memory.get_stuff_as_list("related_file_paths", item_type=FilePath)
+
+    codebase_files: List[CodebaseFileContent] = []
+    for file_path in file_paths_list.items:
+        try:
+            with open(file_path.path, "r", encoding="utf-8") as file:
+                content = file.read()
+                codebase_files.append(CodebaseFileContent(file_path=file_path.path, file_content=content))
+        except Exception as e:
+            codebase_files.append(
+                CodebaseFileContent(file_path=file_path.path, file_content=f"# File not found or unreadable: {file_path.path}\n# Error: {str(e)}")
+            )
+
+    return ListContent[CodebaseFileContent](items=codebase_files)
+
+
+func_registry.register_function(read_file_content, name="read_file_content")