Runs and polling

const run = await client.runs.create({
  prompt: 'Write a Q4 market memo with supporting charts.',
  template: 'auto',
  blocks: ['document-block', 'excel-block'],
  agent_instructions: 'Keep the tone concise and analytical.',
});

import { readFile } from 'node:fs/promises';

const pdf = await readFile('./reports/q4.pdf');

const run = await client.runs.create({
  prompt: 'Summarise these attachments.',
  files: [
    new Uint8Array(pdf),                                              // raw bytes
    { data: new Uint8Array(pdf), filename: 'q4.pdf' },                // named
    { data: new TextEncoder().encode('# notes'), filename: 'notes.md', contentType: 'text/markdown' },
    new Blob([pdf], { type: 'application/pdf' }),                      // Blob
  ],
});

const terminal = await client.runs.waitForCompletion(run.run_id, {
  pollIntervalMs: 5000,
  timeoutMs: 15 * 60_000,
});

const controller = new AbortController();
setTimeout(() => controller.abort(), 60_000);

try {
  await client.runs.waitForCompletion(run.run_id, { signal: controller.signal });
} catch {
  console.log('cancelled');
}

switch (terminal.status) {
  case 'completed':
    terminal.result.artifacts.forEach((a) => console.log(a.download_url));
    break;
  case 'partial':
    console.warn('partial', terminal.errors);
    terminal.result.artifacts.forEach((a) => console.log(a.download_url));
    break;
  case 'failed':
    console.error(terminal.errors);
    break;
}

for (;;) {
  const run = await client.runs.retrieve(runId);
  if (run.status !== 'running') break;
  console.log(`${run.progress.tasks_completed}/${run.progress.tasks_total}`);
  await new Promise((r) => setTimeout(r, 10_000));
}