Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/extract-dpe.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/extract-gantt.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/extract-generic.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/extract-proof-of-purchase.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/extract-table.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/hello-world.md
Original file line number Diff line number Diff line change
Expand Up @@ -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",
)

Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/invoice-extractor.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/simple-ocr.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/write-screenplay.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/cookbook-examples/write-tweet.md
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down
2 changes: 1 addition & 1 deletion docs/pages/quick-start/index.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
@@ -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" }]
Expand Down
Loading