Observability

import time

after = None
while True:
    page = client.runs.events(run.id, after=after)
    for event in page.events:
        print(event.type, event.data)
    after = page.next_after if page.next_after is not None else after

    status = client.runs.status(run.id).status.value
    if status in {"completed", "failed", "cancelled"}:
        break
    time.sleep(1)

let after: number | undefined;
while (true) {
  const page = await client.runs.events(run.id, { after });
  for (const event of page.events) {
    console.log(event.type, event.data);
  }
  after = page.nextAfter ?? after;

  const { status } = await client.runs.status(run.id);
  if (["completed", "failed", "cancelled"].includes(status)) break;
  await new Promise((resolve) => setTimeout(resolve, 1000));
}