persevere-plumbing 1.0.0

Typed composition algebra for wiring LLM agent pipelines

Persevere Plumbing

A typed composition algebra for wiring LLM agent pipelines. Plumbing is a pipeline language and runtime where agents are Unix processes, channels are Unix pipes, and types are validated at every channel boundary. You declare processes and their types in .plumb files, then compose them using a small algebra of stream morphisms.

Installation

Pre-built wheels are available for macOS (arm64) and Linux (x86_64). Not yet on PyPI — install from the wheel file:

pip install persevere_plumbing-*.whl

Quick start

Type-check a pipeline

import persevere.plumbing as pb
from pathlib import Path

result = pb.check(Path("pipeline.plumb"))
print(result.bindings)    # declared processes and their types

One-shot execution

results = pb.call_sync(Path("pipeline.plumb"), "hello")

Streaming execution

import asyncio
import persevere.plumbing as pb
from pathlib import Path

async def main():
    async with await pb.run(Path("pipeline.plumb")) as pipeline:
        await pipeline.send("hello")
        response = await pipeline.recv()
        print(response)

asyncio.run(main())

Build pipelines in Python

The persevere.plumbing.dsl subpackage lets you construct pipelines as Python objects that render to .plumb source text:

from persevere.plumbing.dsl import Program, Agent

prog = Program()
prog.let("writer", input=str, output=str,
    impl=Agent(model="claude-sonnet-4-5-20250514"))
results = prog.call_sync("Write a haiku about types")

Platform availability

• macOS arm64 (Apple Silicon)
• Linux x86_64

Documentation

Full documentation is included in the source repository under doc/:

• Python bindings — complete API reference for check(), call_sync(), run(), and the DSL
• Language reference — .plumb syntax, types, modules, protocols

Licence

Copyright (c) 2026 Leith Document Company Limited. Free for non-commercial use (personal learning, academic research, hobby projects). Commercial use requires a licence — contact [e-mail]. See LICENSE for full terms.