Start runs from your backend

// No thread: a one-off run. POST /v1/agents/:id/runs is REST-only today — the
// SDK's request helper is private, so use fetch for this one call, then the SDK for the rest.
const res = await fetch(`${process.env.HIVE_API_URL}/v1/agents/${AGENT_ID}/runs`, {
  method: 'POST',
  headers: {
    authorization: `Bearer ${process.env.HIVE_API_KEY}`,
    'x-tenant-id': process.env.HIVE_TENANT_ID!,
    'content-type': 'application/json',
  },
  body: JSON.stringify({ input: { text: 'Summarise the refund policy for damaged items in two sentences.' } }),
});
const { run_id } = (await res.json()) as { run_id: string };   // 202
const run = await hive.runs.waitForCompletion(run_id);

# One-off run, then poll
curl -X POST https://console.agenticworkforce.me/v1/agents/$AGENT_ID/runs \
  -H "Authorization: Bearer $HIVE_API_KEY" -H "X-Tenant-Id: $HIVE_TENANT_ID" \
  -H "Content-Type: application/json" \
  -d '{"input":{"text":"Summarise the refund policy for damaged items."}}'
# → 202 { "run_id": "…" }

curl https://console.agenticworkforce.me/v1/runs/$RUN_ID \
  -H "Authorization: Bearer $HIVE_API_KEY" -H "X-Tenant-Id: $HIVE_TENANT_ID"
# → { "run": { "status": "succeeded", "output": { "text": "…" }, "origin": {…}, … }, "steps": [ … ] }

# Stream instead of polling
curl -N https://console.agenticworkforce.me/v1/runs/$RUN_ID/events?since=-1 \
  -H "Accept: text/event-stream" \
  -H "Authorization: Bearer $HIVE_API_KEY" -H "X-Tenant-Id: $HIVE_TENANT_ID"

// REST without the SDK: start, then consume SSE with fetch.
const started = await hive<{ run_id: string }>('POST', `/v1/agents/${AGENT_ID}/runs`, {
  input: { text: 'Summarise the refund policy for damaged items.' },
});

const res = await fetch(`${process.env.HIVE_API_URL}/v1/runs/${started.run_id}/events?since=-1`, {
  headers: {
    accept: 'text/event-stream',
    authorization: `Bearer ${process.env.HIVE_API_KEY}`,
    'x-tenant-id': process.env.HIVE_TENANT_ID!,
  },
});
const reader = res.body!.pipeThrough(new TextDecoderStream()).getReader();
let buffer = '';
for (;;) {
  const { value, done } = await reader.read();
  if (done) break;
  buffer += value;
  let sep: number;
  while ((sep = buffer.indexOf('\n\n')) !== -1) {
    const frame = buffer.slice(0, sep);
    buffer = buffer.slice(sep + 2);
    const data = frame.split('\n').find((l) => l.startsWith('data: '))?.slice(6);
    if (data === undefined) continue;
    const event = JSON.parse(data) as { type: string; [k: string]: unknown };
    if (event.type === 'run.completed' || event.type === 'run.failed') console.log(event);
  }
}

import json

# Start (one-off run), then follow the SSE stream with requests.
started = hive("POST", f"/v1/agents/{AGENT_ID}/runs",
               json={"input": {"text": "Summarise the refund policy for damaged items."}})
run_id = started["run_id"]

with session.get(HIVE + f"/v1/runs/{run_id}/events", params={"since": -1},
                 headers={"Accept": "text/event-stream"}, stream=True, timeout=120) as res:
    for line in res.iter_lines(decode_unicode=True):
        if not line.startswith("data: "):
            continue
        event = json.loads(line[6:])
        if event["type"] == "llm.delta":
            print(event["text"], end="", flush=True)
        elif event["type"] in ("run.completed", "run.failed"):
            print("\n", event)
            break

# Or poll: GET /v1/runs/{run_id} until status is terminal
run = hive("GET", f"/v1/runs/{run_id}")["run"]

var start = await hive.PostAsJsonAsync($"/v1/agents/{agentId}/runs",
    new { input = new { text = "Summarise the refund policy for damaged items." } });
var runId = (await start.Content.ReadFromJsonAsync<Dictionary<string, string>>())!["run_id"];

// Poll until terminal (or open /v1/runs/{id}/events with Accept: text/event-stream)
while (true)
{
    var run = await hive.GetFromJsonAsync<System.Text.Json.JsonElement>($"/v1/runs/{runId}");
    var status = run.GetProperty("run").GetProperty("status").GetString();
    if (status is "succeeded" or "failed" or "cancelled") { Console.WriteLine(run); break; }
    await Task.Delay(1000);
}

HttpRequest start = HttpRequest.newBuilder(URI.create(base + "/v1/agents/" + agentId + "/runs"))
    .header("Authorization", "Bearer " + System.getenv("HIVE_API_KEY"))
    .header("X-Tenant-Id", System.getenv("HIVE_TENANT_ID"))
    .header("Content-Type", "application/json")
    .POST(HttpRequest.BodyPublishers.ofString(
        "{\"input\":{\"text\":\"Summarise the refund policy for damaged items.\"}}"))
    .build();
String runId = new ObjectMapper().readTree(http.send(start, HttpResponse.BodyHandlers.ofString()).body())
    .get("run_id").asText();

// Poll GET /v1/runs/{id} until run.status is succeeded | failed | cancelled,
// or stream GET /v1/runs/{id}/events with Accept: text/event-stream.