Covenant Compute for Microsoft Agent Framework.

curl --fail --location --output covenant_compute_x402-0.1.0-py3-none-any.whl \
  https://github.com/open-covenant/covenant/releases/download/codex-compute-x402-python-v0.1.0/covenant_compute_x402-0.1.0-py3-none-any.whl &&
echo "0613775ced5316871b2248fd9942b523cee548e8e53e8222e8db614165023325  covenant_compute_x402-0.1.0-py3-none-any.whl" | shasum -a 256 -c - &&
python -m pip install './covenant_compute_x402-0.1.0-py3-none-any.whl[agent-framework]'

import json
from agent_framework import Agent
from covenant_compute_x402.agent_framework import covenant_inference_tool

# Save the request UUID before the first run. Load it again after a restart.
with open("./state/run.json") as file:
    request_id = json.load(file)["requestId"]

compute = covenant_inference_tool(
    client=client,  # Configured wallet, journal and spending limits.
    request_id=request_id,
    model="claude-haiku-4.5",
    max_tokens=2048,
    temperature=0.2,
    system_prompt="Prepare a draft for review. Do not claim actions were performed.",
)

agent = Agent(
    client=planner,  # Your application's separately budgeted planner.
    instructions="Review the incident and identify evidence still needed.",
    tools=[compute],
)

# The model supplies only {"prompt": "..."}.
# Wallet, model, purchase identity and spending limits stay in application code.
result = await agent.run(incident_report)

from covenant_compute_x402.workflow_demo import run_demo

# Reuse this configuration, state directory and request UUID in every process.
run = dict(
    client=client,
    state_dir="./state/incident-review",
    request_id=request_id,
    workflow_id=workflow_id,
    model="claude-haiku-4.5",
)

# 1. The planner selects a tool. The workflow checkpoints before payment.
plan = await run_demo("plan", planner=planner, **run)

# 2. A new process resumes the exact saved tool call.
purchase = await run_demo("purchase", **run)
if purchase["purchase"]["status"] != "completed":
    # Keep the same state and identity; resume purchase to reconcile it.
    raise RuntimeError("Purchase pending; no completed answer yet.")

# 3. Replaying the saved call returns the completed purchase from the journal.
replay = await run_demo("replay", **run)

# 4. Continue with the verified answer. This phase has no paid inference tool.
review = await run_demo("finish", planner=planner, **run)