Merge pull request Pipelex#186 from Pipelex/dev

thomashebrard · web-flow · commit e9fe0c09fc75 · 2025-07-21T09:30:52.000+02:00
dev to release/v0.6.5
diff --git a/docs/pages/build-reliable-ai-workflows-with-pipelex/design_and_run_pipelines.md b/docs/pages/build-reliable-ai-workflows-with-pipelex/design_and_run_pipelines.md
@@ -138,7 +138,7 @@ async def main():
     )
 
     # Execute the pipeline and wait for the result
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="description_to_tagline",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/extract-dpe.md b/docs/pages/cookbook-examples/extract-dpe.md
@@ -17,7 +17,7 @@ async def extract_dpe(pdf_url: str) -> Dpe:
         concept_str="PDF",
         name="pdf",
     )
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="power_extractor_dpe",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/extract-gantt.md b/docs/pages/cookbook-examples/extract-gantt.md
@@ -20,7 +20,7 @@ async def extract_gantt(image_url: str) -> GanttChart:
     )
 
     # Run the pipe
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="extract_gantt_by_steps",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/extract-generic.md b/docs/pages/cookbook-examples/extract-generic.md
@@ -17,7 +17,7 @@ async def extract_generic(pdf_url: str) -> TextAndImagesContent:
         concept_str="PDF",
         name="pdf",
     )
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="power_extractor",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/extract-proof-of-purchase.md b/docs/pages/cookbook-examples/extract-proof-of-purchase.md
@@ -17,7 +17,7 @@ async def extract_proof_of_purchase(pdf_url: str) -> ProofOfPurchase:
         concept_str="PDF",
         name="pdf",
     )
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="power_extractor_proof_of_purchase",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/extract-table.md b/docs/pages/cookbook-examples/extract-table.md
@@ -17,7 +17,7 @@ async def extract_table(table_screenshot: str) -> HtmlTable:
         concept_str="tables.TableScreenshot",
         name="table_screenshot",
     )
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="extract_html_table_and_review",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/hello-world.md b/docs/pages/cookbook-examples/hello-world.md
@@ -25,7 +25,7 @@ from pipelex.pipeline.execute import execute_pipeline
 async def hello_world():
 
     # Execute the pipeline
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="hello_world",
     )
 
diff --git a/docs/pages/cookbook-examples/invoice-extractor.md b/docs/pages/cookbook-examples/invoice-extractor.md
@@ -19,7 +19,7 @@ async def process_expense_report() -> ListContent[Invoice]:
         pdf_url=invoice_pdf_path,
         name="invoice_pdf",
     )
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="process_invoice",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/simple-ocr.md b/docs/pages/cookbook-examples/simple-ocr.md
@@ -19,7 +19,7 @@ async def simple_ocr(pdf_url: str):
         concept_str="PDF",
         name="pdf",
     )
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="extract_page_contents_from_pdf",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/write-screenplay.md b/docs/pages/cookbook-examples/write-screenplay.md
@@ -25,7 +25,7 @@ async def generate_screenplay(pitch: str):
     working_memory = WorkingMemoryFactory.make_from_single_stuff(pitch_stuff)
 
     # Run the pipe
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="generate_screenplay",
         working_memory=working_memory,
     )
diff --git a/docs/pages/cookbook-examples/write-tweet.md b/docs/pages/cookbook-examples/write-tweet.md
@@ -33,7 +33,7 @@ async def optimize_tweet(draft_tweet_str: str, writing_style_str: str) -> Optimi
     )
 
     # Run the sequence pipe
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="optimize_tweet_sequence",
         working_memory=working_memory,
     )
diff --git a/docs/pages/quick-start/index.md b/docs/pages/quick-start/index.md
@@ -40,7 +40,7 @@ from pipelex.pipelex import Pipelex
 
 async def create_character():
     # Run the script with execute_pipe
-    pipe_output, _ = await execute_pipeline(
+    pipe_output = await execute_pipeline(
         pipe_code="create_character",
     )
     # Print the output
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "pipelex"
-version = "0.6.4"
+version = "0.6.5"
 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" }]

Original file line number	Diff line number	Diff line change
`@@ -138,7 +138,7 @@ async def main():`
`138`	`138`	`)`
`139`	`139`
`140`	`140`	`# Execute the pipeline and wait for the result`
`141`		`- pipe_output, _ = await execute_pipeline(`
	`141`	`+ pipe_output = await execute_pipeline(`
`142`	`142`	`pipe_code="description_to_tagline",`
`143`	`143`	`working_memory=working_memory,`
`144`	`144`	`)`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ async def extract_dpe(pdf_url: str) -> Dpe:`
`17`	`17`	`concept_str="PDF",`
`18`	`18`	`name="pdf",`
`19`	`19`	`)`
`20`		`- pipe_output, _ = await execute_pipeline(`
	`20`	`+ pipe_output = await execute_pipeline(`
`21`	`21`	`pipe_code="power_extractor_dpe",`
`22`	`22`	`working_memory=working_memory,`
`23`	`23`	`)`
Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ async def extract_gantt(image_url: str) -> GanttChart:`
`20`	`20`	`)`
`21`	`21`
`22`	`22`	`# Run the pipe`
`23`		`- pipe_output, _ = await execute_pipeline(`
	`23`	`+ pipe_output = await execute_pipeline(`
`24`	`24`	`pipe_code="extract_gantt_by_steps",`
`25`	`25`	`working_memory=working_memory,`
`26`	`26`	`)`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ async def extract_generic(pdf_url: str) -> TextAndImagesContent:`
`17`	`17`	`concept_str="PDF",`
`18`	`18`	`name="pdf",`
`19`	`19`	`)`
`20`		`- pipe_output, _ = await execute_pipeline(`
	`20`	`+ pipe_output = await execute_pipeline(`
`21`	`21`	`pipe_code="power_extractor",`
`22`	`22`	`working_memory=working_memory,`
`23`	`23`	`)`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ async def extract_proof_of_purchase(pdf_url: str) -> ProofOfPurchase:`
`17`	`17`	`concept_str="PDF",`
`18`	`18`	`name="pdf",`
`19`	`19`	`)`
`20`		`- pipe_output, _ = await execute_pipeline(`
	`20`	`+ pipe_output = await execute_pipeline(`
`21`	`21`	`pipe_code="power_extractor_proof_of_purchase",`
`22`	`22`	`working_memory=working_memory,`
`23`	`23`	`)`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ async def extract_table(table_screenshot: str) -> HtmlTable:`
`17`	`17`	`concept_str="tables.TableScreenshot",`
`18`	`18`	`name="table_screenshot",`
`19`	`19`	`)`
`20`		`- pipe_output, _ = await execute_pipeline(`
	`20`	`+ pipe_output = await execute_pipeline(`
`21`	`21`	`pipe_code="extract_html_table_and_review",`
`22`	`22`	`working_memory=working_memory,`
`23`	`23`	`)`
Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ from pipelex.pipeline.execute import execute_pipeline`
`25`	`25`	`async def hello_world():`
`26`	`26`
`27`	`27`	`# Execute the pipeline`
`28`		`- pipe_output, _ = await execute_pipeline(`
	`28`	`+ pipe_output = await execute_pipeline(`
`29`	`29`	`pipe_code="hello_world",`
`30`	`30`	`)`
`31`	`31`
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ async def process_expense_report() -> ListContent[Invoice]:`
`19`	`19`	`pdf_url=invoice_pdf_path,`
`20`	`20`	`name="invoice_pdf",`
`21`	`21`	`)`
`22`		`- pipe_output, _ = await execute_pipeline(`
	`22`	`+ pipe_output = await execute_pipeline(`
`23`	`23`	`pipe_code="process_invoice",`
`24`	`24`	`working_memory=working_memory,`
`25`	`25`	`)`
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ async def simple_ocr(pdf_url: str):`
`19`	`19`	`concept_str="PDF",`
`20`	`20`	`name="pdf",`
`21`	`21`	`)`
`22`		`- pipe_output, _ = await execute_pipeline(`
	`22`	`+ pipe_output = await execute_pipeline(`
`23`	`23`	`pipe_code="extract_page_contents_from_pdf",`
`24`	`24`	`working_memory=working_memory,`
`25`	`25`	`)`
Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ async def generate_screenplay(pitch: str):`
`25`	`25`	`working_memory = WorkingMemoryFactory.make_from_single_stuff(pitch_stuff)`
`26`	`26`
`27`	`27`	`# Run the pipe`
`28`		`- pipe_output, _ = await execute_pipeline(`
	`28`	`+ pipe_output = await execute_pipeline(`
`29`	`29`	`pipe_code="generate_screenplay",`
`30`	`30`	`working_memory=working_memory,`
`31`	`31`	`)`