kigumi 0.7.1

Load-bearing joinery for LLM content pipelines: context injection, validated repair loops, deterministic replay, DAG orchestration.

kigumi (木組)

English | 中文

Nail-free interlocking joinery. The load-bearing structural layer for LLM content pipelines — connecting your project (the roof) to the model (the pillars) through precise joints: output that does not fit the mortise gets sent back for rework.

A foundation for building LLM pipelines with coding agents:

• Injection and assembly: a single entry point for material injection, strict template rendering, format sections auto-generated from schemas
• Layered Prompt declarations: finite selector axes, fixed fragments and fenced runtime materials resolve before cache lookup, with selected-only L3 caching and content-free lineage
• Repair loop: failed validation turns into corrective instructions, model context is preserved, retries are bounded, lessons are locked in
• Deterministic replay: content-addressed caching — same input, byte-identical output
• DAG orchestration (optional): explicit node/item cache policy, static reusable subgraphs, dynamic map/scan, owned materialized outputs, human checkpoints, durable retry/resume, and run diffs
• External Agent nodes: provider-neutral staged execution with captured attachments, exact publication, ordinary DAG caching, content-addressed AgentSpec capsules, global cross-process capacity, evidence retention policies, and a native, exactly versioned Pi RPC adapter
• Typed failures and explicit recovery: shared provider failure facts, deterministic retry schedules, persisted attempt receipts, and fail-closed handling of ambiguous side effects
• Workflow profiles: one canonical static/runtime IR for Prompt-aware Mermaid, Markdown, JSON, describe, trace, and run inspection
• Experiment subjects: one isolated evidence grid for functions, callers, ordinary workflows, and Agent-backed DAGs—without automatic winner selection
• Four guard rings: registration-time refusal plus three outer rings (dag check / pytest auto-collection / git hooks), so the rules enforce themselves

Quick start

from pathlib import Path

from pydantic import BaseModel

from kigumi import LiteLLMTransport, LLMCaller, call_validated


class Verdict(BaseModel):
    score: int
    reason: str


transport = LiteLLMTransport(aliases={"default": "anthropic/claude-sonnet-5"})
caller = LLMCaller(transport, cache_dir=Path("artifacts/_llm"), seed=20260713)

verdict = call_validated(caller, "Score this opening scene and explain why: ...", Verdict)

call_validated automatically appends a format section generated from Verdict; a response that does not fit is sent back with the validation errors for a bounded number of retries (2 by default). The whole exchange lands in a content-addressed cache, so the same input replays byte-for-byte with no further API cost.

Status

0.7.1, API not frozen. The Agent boundary is intentionally an execution adapter, not an autonomous factory or optimizer.

Layered Prompt example

from kigumi import InputRef, PromptAxis, PromptLayer, PromptRef, PromptSpec

WRITE = PromptSpec(
    name="write",
    base=PromptRef("base/task"),
    layers=(
        PromptLayer(
            slot="mode",
            source=PromptAxis(
                name="mode",
                selector=InputRef("config", path=("mode",)),
                variants={
                    "concise": PromptRef("variants/concise"),
                    "detailed": PromptRef("variants/detailed"),
                },
            ),
        ),
    ),
)


@dag.node("write", deps=("config",), prompt_specs=(WRITE,))
def write(inputs, ctx):
    return {"text": ctx.call(ctx.resolve_prompt("write"))}

Kigumi snapshots all declared Prompt files once per run. The selected variant enters the L3 key; unselected variant bytes remain in run identity, so editing one can reuse the selected cache but cannot silently resume an old run. Inspect the complete declaration or persisted selections with dag profile and dag graph --prompts.

Install

uv add "kigumi[litellm]"

Without the litellm extra you can use StdlibTransport (pure-stdlib HTTP) or implement your own transport. Pi is an external runtime: install it yourself, pin its version, and pass the executable plus exact version to PiRpcAdapter. Kigumi never installs or upgrades Node/Pi. The staged, root-scoped tool boundary limits model tool I/O but is not an OS sandbox; trusted Pi Extensions retain host-process permissions.

Automatic DAG retry is off by default. When a node declares RetryPolicy, Kigumi persists run/attempt state and returns pending instead of sleeping; an external supervisor calls Dag.resume() when due. EvidencePolicy controls retention after mandatory secret scrubbing, but is not encryption or access control. 0.6 runs remain inspectable as legacy profiles but cannot be resumed under the 0.7 manifest.

Documentation map

Documentation is currently written in Chinese.

Document	The question it answers
DESIGN.md	Why it is designed this way; layers, boundaries, settled trade-offs
docs/adoption.md	How to adopt it; the path from a single caller to a DAG, plus troubleshooting
docs/contracts/	Which behaviors are promises; invariants, failure behavior, verification coordinates
docs/reviews/	What a review found at a point in time; descriptive records, not specs
CHANGELOG.md	What changed; cache-family rotations and breaking changes are always recorded
AGENTS.md	What an agent reads before entering; red lines and verification commands

License

MIT