Call the studio from your code

import timeimport uuidimport httpxBASE = "http://127.0.0.1:8420/v1/studio"def retryable(status: int, code: str) -> bool:    """A busy or restarting model is worth another try; a 400 is a mistake in the request."""    return status in (429, 500, 503, 504) or code == "idempotency_in_progress"class StudioError(Exception):    def __init__(self, status: int, error: dict):        super().__init__(f"{status} {error['code']}: {error['message']}")        self.status, self.code, self.error = status, error["code"], errordef decide(body: dict, *, key: str | None = None, attempts: int = 4) -> dict:    """POST /decisions with one idempotency key for every attempt, so a retry never makes a second decision."""    key = key or str(uuid.uuid4())    with httpx.Client(base_url=BASE, timeout=120) as client:        for attempt in range(attempts):            r = client.post("/decisions", json=body, headers={"Idempotency-Key": key})            if r.status_code == 200:                return r.json()            error = r.json()["error"]            if not retryable(r.status_code, error["code"]) or attempt == attempts - 1:                raise StudioError(r.status_code, error)            time.sleep(float(r.headers.get("retry-after", 2 ** attempt)))d = decide({"template": "support-triage",            "variables": {"customer_message": "We were billed twice for March. Refund the duplicate today.",                          "account_tier": "pro"},            "metadata": {"ticket_id": "T-5132"}},           key="ticket-T-5132-triage")print(d["id"], d["act"], d["needs_review"])try:    decide({"template": "support-triage", "variables": {"customer_message": "Hello", "account_tier": "gold"}})except StudioError as e:    print(e.status, e.code, e.error["param"])

const BASE = "http://127.0.0.1:8420/v1/studio";class StudioError extends Error {  constructor(status, error) {    super(`${status} ${error.code}: ${error.message}`);    Object.assign(this, { status, code: error.code, error });  }}const retryable = (status, code) => [429, 500, 503, 504].includes(status) || code === "idempotency_in_progress";const sleep = (ms) => new Promise((r) => setTimeout(r, ms));// POST /decisions with one idempotency key for every attempt, so a retry never makes a second decision.export async function decide(body, { key = crypto.randomUUID(), attempts = 4 } = {}) {  for (let attempt = 0; ; attempt++) {    const res = await fetch(`${BASE}/decisions`, {      method: "POST",      headers: { "Content-Type": "application/json", "Idempotency-Key": key },      body: JSON.stringify(body),      signal: AbortSignal.timeout(120_000),    });    const data = await res.json();    if (res.ok) return data;    if (!retryable(res.status, data.error.code) || attempt === attempts - 1) throw new StudioError(res.status, data.error);    await sleep(1000 * Number(res.headers.get("retry-after") ?? 2 ** attempt));  }}const d = await decide({  template: "support-triage",  variables: { customer_message: "We were billed twice for March. Refund the duplicate today.", account_tier: "pro" },  metadata: { ticket_id: "T-5133" },}, { key: "ticket-T-5133-triage" });console.log(d.id, d.act, d.needs_review);

curl -s -i http://127.0.0.1:8420/v1/studio/decisions \  -H 'Idempotency-Key: ticket-T-5130-triage' -d '{  "template": "support-triage",  "variables": {"customer_message": "Our invoice shows 60 seats but we only have 45 users.",                "account_tier": "pro"},  "metadata": {"ticket_id": "T-5130"}}'

curl -s http://127.0.0.1:8420/v1/studio/decisions -d '{  "template": "support-triage",  "variables": {"customer_message": "Please add two more seats to our plan.", "account_tier": "pro"},  "background": true}'curl -s 'http://127.0.0.1:8420/v1/studio/decisions/dec_01M3TFCCP5NWDT2WSQ8P7DHXKZ?wait=60'

import httpxstudio = httpx.Client(base_url="http://127.0.0.1:8420/v1/studio", timeout=90)d = studio.post("/decisions", json={    "template": "support-triage",    "variables": {"customer_message": "Please add two more seats to our plan.", "account_tier": "pro"},    "background": True,}).raise_for_status().json()while d["status"] in ("queued", "in_progress"):    d = studio.get(f"/decisions/{d['id']}", params={"wait": 60}).raise_for_status().json()