Running a workflow

{
  "deployment_id": "your-deployment-id",
  "inputs": {
    "input_text": "a lighthouse at dusk",
    "input_image": "https://example.com/reference.png"
  }
}

{ "run_id": "..." }

{
  "id": "...",
  "workflow_id": "...",
  "workflow_version_id": "...",
  "machine_id": "...",
  "workflow_inputs": {
    "input_text": "a lighthouse at dusk",
    "input_image": "https://somestatic.png"
  },
  "origin": "api",
  "status": "success",
  "created_at": "...",
  "started_at": "...",
  "ended_at": "..."
}

async function waitForRun(client, runId, {
  intervalMs = 2000,
  timeoutMs = 600000,
} = {}) {
  const deadline = Date.now() + timeoutMs;

  while (Date.now() < deadline) {
    const run = await client.getWorkflowOutput(runId);

    if (run.status === 'success') return run;
    if (run.status === 'failed') throw new Error(`Run ${runId} failed`);

    await new Promise((resolve) => setTimeout(resolve, intervalMs));
  }

  throw new Error(`Run ${runId} timed out after ${timeoutMs}ms`);
}