Arbiter + CrewAI

import os, time, requests
from typing import Optional

ARBITER_BASE = "https://arbiter-2.polsia.app"
HEADERS = {
    "Authorization": "Bearer " + os.environ["ARBITER_API_KEY"],
    "Content-Type": "application/json",
}

def register_crew_agent(agent_id: str, name: str, sla: dict) -> Optional[int]:
    """Register a CrewAI agent. 409 = already registered, safe to ignore."""
    r = requests.post(ARBITER_BASE + "/api/agents", headers=HEADERS, json={
        "external_agent_id": agent_id, "name": name,
        "platform": "crewai", "sla_policy": sla,
    })
    if r.status_code not in (200, 201, 409):
        r.raise_for_status()
    return r.json().get("id")

def submit_dispute(description: str, chain: list) -> dict:
    r = requests.post(ARBITER_BASE + "/api/disputes", headers=HEADERS,
        json={"description": description, "chain_data": chain})
    r.raise_for_status()
    return r.json()

def await_resolution(dispute_id: int, timeout: int = 10) -> Optional[dict]:
    deadline = time.time() + timeout
    while time.time() < deadline:
        r = requests.get(
            ARBITER_BASE + "/api/disputes/" + str(dispute_id) + "/resolution",
            headers=HEADERS)
        if r.status_code == 200:
            return r.json()
        if r.status_code != 404:
            r.raise_for_status()
        time.sleep(0.5)
    return None


# ── Wire into CrewAI task callbacks ─────────────────────────────────

# 1. Register at startup (idempotent)
register_crew_agent("crewai-researcher-001", "Research Agent",
    sla={"refund_window_hours": 24, "max_retry_attempts": 3})
register_crew_agent("crewai-writer-002", "Writer Agent",
    sla={"refund_window_hours": 12, "quality_threshold": 0.9})

# 2. On task failure, submit the chain
dispute = submit_dispute(
    description="Writer produced output that failed validation",
    chain=[
        {"agent_id": "crewai-researcher-001", "action": "delivered_research_summary",
         "timestamp": "2026-04-28T10:00:00Z", "outcome": "success"},
        {"agent_id": "crewai-writer-002", "action": "generated_report",
         "timestamp": "2026-04-28T10:00:30Z", "outcome": "failed",
         "error": "missing_required_sections", "amount": 12.50},
    ])

# 3. Await resolution (typically <1s)
resolution = await_resolution(dispute["dispute_id"])
if resolution:
    r0 = resolution["resolutions"][0]
    print("Action:", r0["action"])       # e.g. "full_refund"
    print("Reasoning:", r0["reasoning"])
else:
    print("Timed out — dispute queued for manual review")

npm install arbiter-client

import { ArbiterClient } from 'arbiter-client';

const arbiter = new ArbiterClient({
  apiKey: process.env.ARBITER_API_KEY!,
  baseUrl: 'https://arbiter-2.polsia.app',
});

// Register agents once at startup (idempotent)
async function ensureAgentsRegistered() {
  const agents = [
    { external_agent_id: 'crewai-researcher-001', name: 'Research Agent',
      platform: 'crewai', sla_policy: { refund_window_hours: 24 } },
    { external_agent_id: 'crewai-writer-002', name: 'Writer Agent',
      platform: 'crewai', sla_policy: { quality_threshold: 0.9 } },
  ];
  for (const agent of agents) {
    try { await arbiter.registerAgent(agent); }
    catch (err: any) { if (err?.status !== 409) throw err; }
  }
}

// Submit dispute and await resolution
async function handleCrewTaskFailure(description: string, chain: any[]) {
  const dispute = await arbiter.submitDispute(chain, { description });

  let resolution = null;
  for (let i = 0; i < 20; i++) {
    try {
      resolution = await arbiter.getResolution(dispute.dispute_id);
      break;
    } catch (err: any) {
      if (err?.status !== 404) throw err;
      await new Promise(r => setTimeout(r, 500));
    }
  }
  if (!resolution) { console.warn('Resolution timed out'); return null; }

  const { action, reasoning, fault_agent_id } = resolution.resolutions[0];
  console.log('Resolution:', action, '| Fault:', fault_agent_id);
  console.log('Reasoning:', reasoning);
  return resolution;
}

// Run
await ensureAgentsRegistered();
await handleCrewTaskFailure('Writer produced output that failed validation', [
  { agent_id: 'crewai-researcher-001', action: 'delivered_research_summary',
    timestamp: '2026-04-28T10:00:00Z', outcome: 'success' },
  { agent_id: 'crewai-writer-002', action: 'generated_report',
    timestamp: '2026-04-28T10:00:30Z', outcome: 'failed',
    error: 'missing_required_sections', amount: 12.50 },
]);