Pyrula

Pyrula runs durable workflows and LLM agents that survive crashes and resume where they left off. Over Kafka, an agent’s output and its offset commit can be bound into one transaction for read-process-write pipelines. Underneath is a fast, typed functional core (Either, Option, Try, immutable IList/IMap, Rust-backed serde) that everything is built on.

Install what you need. Each piece ships as its own package and depends on the core.

pip install pyrula

Core Primitives Rust-backed Either, Option, Try, immutable IList/IMap, serde. Durable Workflows Append-only run streams. Replay after a crash, resume where you left off. Build Agents The @agent / @tool model, streaming, and an HTTP surface. Stream Kafka confluent-kafka semantics with explicit timeouts and EOS. Move Pipelines Exactly-once Kafka, Delta, and Postgres connectors on an Arrow engine.

New here? Start with Install, then the Quickstart.