Batch Processing

# Start the run
curl -X POST "https://api.sixtyfour.ai/workflows/run?workflow_id=WORKFLOW_ID" \
  -H "x-api-key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "webhook_payload": [
      {"name": "Sarah Chen", "company": "Pacific View Studios"},
      {"name": "James Park", "company": "Northgate Labs"}
    ]
  }'

# Poll with the job_id from the response
curl "https://api.sixtyfour.ai/workflows/runs/JOB_ID/live_status" \
  -H "x-api-key: YOUR_API_KEY"

# Get download links once overall_status is completed
curl "https://api.sixtyfour.ai/workflows/runs/JOB_ID/results/download-links" \
  -H "x-api-key: YOUR_API_KEY"

import time, requests

BASE = "https://api.sixtyfour.ai"
HEADERS = {"x-api-key": "YOUR_API_KEY"}

run = requests.post(
    f"{BASE}/workflows/run",
    params={"workflow_id": "WORKFLOW_ID"},
    headers=HEADERS,
    json={"webhook_payload": [
        {"name": "Sarah Chen", "company": "Pacific View Studios"},
        {"name": "James Park", "company": "Northgate Labs"},
    ]},
)
run.raise_for_status()
job_id = run.json()["job_id"]

IN_PROGRESS = {"queued", "running", "finalizing"}
while True:
    resp = requests.get(f"{BASE}/workflows/runs/{job_id}/live_status", headers=HEADERS)
    if resp.status_code in (429, 503):
        time.sleep(int(resp.headers.get("Retry-After", 10)))
        continue
    resp.raise_for_status()
    status = resp.json()
    if status["overall_status"] not in IN_PROGRESS:
        break
    time.sleep(10)

if status["overall_status"] != "completed":
    raise RuntimeError(f"Run ended as {status['overall_status']}")

links = requests.get(f"{BASE}/workflows/runs/{job_id}/results/download-links", headers=HEADERS).json()
final = next(item for item in links if item["filename"] == f"{job_id}.csv")
csv_file = requests.get(final["download_url"], headers=HEADERS)
csv_file.raise_for_status()
with open("results.csv", "wb") as f:
    f.write(csv_file.content)

import fs from "node:fs/promises";

const BASE = "https://api.sixtyfour.ai";
const headers = { "x-api-key": "YOUR_API_KEY", "Content-Type": "application/json" };

const run = await fetch(`${BASE}/workflows/run?workflow_id=WORKFLOW_ID`, {
  method: "POST",
  headers,
  body: JSON.stringify({
    webhook_payload: [
      { name: "Sarah Chen", company: "Pacific View Studios" },
      { name: "James Park", company: "Northgate Labs" },
    ],
  }),
});
const { job_id } = await run.json();

const IN_PROGRESS = ["queued", "running", "finalizing"];
let status;
while (true) {
  const resp = await fetch(`${BASE}/workflows/runs/${job_id}/live_status`, { headers });
  if (resp.status === 429 || resp.status === 503) {
    const retryAfter = Number(resp.headers.get("Retry-After") ?? 10);
    await new Promise((r) => setTimeout(r, retryAfter * 1000));
    continue;
  }
  if (!resp.ok) throw new Error(`Live status failed: ${resp.status}`);
  status = await resp.json();
  if (!IN_PROGRESS.includes(status.overall_status)) break;
  await new Promise((r) => setTimeout(r, 10000));
}

if (status.overall_status !== "completed") throw new Error(`Run ended as ${status.overall_status}`);

const links = await (await fetch(`${BASE}/workflows/runs/${job_id}/results/download-links`, { headers })).json();
const final = links.find((item) => item.filename === `${job_id}.csv`);
const file = await fetch(final.download_url, { headers });
if (!file.ok) throw new Error(`Download failed: ${file.status}`);
await fs.writeFile("results.csv", Buffer.from(await file.arrayBuffer()));