pipe 0.1.0 — atomic, data-in / data-out ops

Compose, don’t glue,
your operations.

A pure, dependency-free core of atomic operations that compose into chains. Import it as a library, or serve that same core as an API on your own cloud — no rewrite.

$ pip install pipe-broker Getting Started →

python ≥ 3.11 free for noncommercial use github.com/amaagracodes/pipe

try it — GET /echo

Input data

chunk

↩ output appears here

Build systems from reusable primitives.

Pipe

One op, one job.

A pure function with a single responsibility — no I/O, no state, no framework. Runs anywhere Python does.

Programming model →

class Upper(pipe.Pipe):
    def forward(self, data: str) -> str:
        return data.upper()

Chain

Compose with >>.

Sequencing lives only in a chain. Output of each stage feeds the next; ops never learn about each other.

Composing →

# detect, then redact
pipeline = DetectPII("us") >> Redact()
pipeline(text)

Experts

Domain expertise as ops.

Jurisdiction-aware domain ops over one uniform envelope. Legal today; more domains to come.

A legal pipeline →

from pipe.lib.experts.legal import DetectPII
 
DetectPII("us/ny")(contract)

Same core. Two surfaces.

Import pipe as a Python library, or serve that exact same core as an HTTP API on your own infrastructure. No rewrite, no lock-in — you own the keys, the data boundary, and the deployment.

Library → REST API →

Serve it anywhere

Edge

Cloudflare Python Worker — pure ops at the edge

Container

Cloud Run, ECS, Fly — the shipped Dockerfile

Anywhere

It’s just an ASGI app — any box that runs Python

Compose, don’t glue,your operations.