Follow a run as it happens

RUN=$(curl -s -X POST "$GORUNNER/api/workflows/$ID/run?environment=production" \
  -H "Authorization: Bearer $GORUNNER_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"name": "Ada Lovelace"}' | jq -r .data.id)

curl -N "$GORUNNER/api/runs/$RUN/stream" \
  -H "Authorization: Bearer $GORUNNER_TOKEN" \
  -H "Accept: text/event-stream"

const res = await fetch(`${GORUNNER}/api/runs/${RUN}/stream`, {
  headers: { Authorization: `Bearer ${TOKEN}`, Accept: "text/event-stream" },
});
if (res.status === 204) process.exit(0); // already over: read the run
const decoder = new TextDecoder();
let buffer = "";
for await (const chunk of res.body) {
  buffer += decoder.decode(chunk, { stream: true });
  let end;
  while ((end = buffer.indexOf("\n\n")) >= 0) {
    const frame = buffer.slice(0, end);
    buffer = buffer.slice(end + 2);
    const data = frame.split("\n").find((l) => l.startsWith("data: "));
    if (!data || /^event:/m.test(frame)) continue; // connected, reconnect
    const ev = JSON.parse(data.slice(6));
    console.log(ev.type, ev.nodeId ?? "", ev.status);
  }
}

import json, requests

with requests.get(
    f"{GORUNNER}/api/runs/{RUN}/stream",
    headers={"Authorization": f"Bearer {TOKEN}",
             "Accept": "text/event-stream"},
    stream=True,
) as res:
    event = None
    for line in res.iter_lines(decode_unicode=True):
        if line.startswith("event: "):
            event = line[7:]  # connected, reconnect
        elif line.startswith("data: ") and event is None:
            ev = json.loads(line[6:])
            print(ev["type"], ev.get("nodeId", ""), ev["status"])
        elif line == "":
            event = None  # a blank line ends a frame