Quickstart

import httpx, threading, time

def muster_emit(job_id, checks, token_input=None, token_output=None, model=None, latency_ms=None):
    """Fire-and-forget. One call covers correctness + cost + latency."""
    def _send():
        try:
            httpx.post(
                f"https://backend.getmuster.io/api/v1/jobs/{job_id}/quality",
                json={
                    "agent_id": "invoice-processor-v2",
                    "job_id": job_id,
                    "overall_passed": all(c["passed"] for c in checks),
                    "checks": checks,
                    "token_input": token_input,   # → cost tracking
                    "token_output": token_output,
                    "model": model,
                    "latency_ms": latency_ms,     # → SLA monitoring
                },
                timeout=2.0,
            )
        except Exception:
            pass  # never block your agent
    threading.Thread(target=_send, daemon=True).start()

# Call after your agent finishes each job
start = time.time()
output = your_agent.run(input)  # your existing code

muster_emit(
    job_id=job_id,
    checks=[
        {"check_id": "output_not_empty",    "severity": "HIGH", "passed": bool(output)},
        {"check_id": "subtotal_arithmetic", "severity": "HIGH",
         "passed": abs(computed - declared) < 0.01,
         "expected": str(declared), "actual": str(computed)},
    ],
    token_input=output.usage.prompt_tokens,      # from your LLM response
    token_output=output.usage.completion_tokens,
    model="gpt-4o",
    latency_ms=int((time.time() - start) * 1000),
)

curl -X POST https://app.getmuster.io/api/v1/jobs/job-001/quality \
  -H "Content-Type: application/json" \
  -d '{
    "agent_id": "invoice-processor-v2",
    "job_id": "job-001",
    "overall_passed": true,
    "checks": [
      {"check_id": "output_not_empty", "severity": "HIGH", "passed": true},
      {"check_id": "subtotal_arithmetic", "severity": "HIGH", "passed": true,
       "expected": "1234.56", "actual": "1234.56"}
    ]
  }'

// Fire and forget
fetch(`https://backend.getmuster.io/api/v1/jobs/${jobId}/quality`, {
  method: "POST",
  headers: { "Content-Type": "application/json" },
  body: JSON.stringify({
    agent_id: "invoice-processor-v2",
    job_id: jobId,
    overall_passed: true,
    checks: [
      { check_id: "output_not_empty", severity: "HIGH", passed: !!output },
    ],
  }),
}).catch(() => {}); // never fail