Workflow Execution

import requests
import time

API_KEY = "YOUR_API_KEY"
WORKFLOW_ID = "YOUR_WORKFLOW_ID"
BASE_URL = "https://api.sixtyfour.ai"
headers = {"x-api-key": API_KEY, "Content-Type": "application/json"}

run_response = requests.post(
    f"{BASE_URL}/workflows/run?workflow_id={WORKFLOW_ID}",
    headers=headers,
    json={
        "webhook_payload": [
            {"company_name": "Acme Corp", "website": "acme.com"},
            {"company_name": "TechStart", "website": "techstart.io"}
        ]
    }
)
run_response.raise_for_status()
job_id = run_response.json()["job_id"]

while True:
    status = requests.get(
        f"{BASE_URL}/workflows/runs/{job_id}/live_status",
        headers=headers
    ).json()
    if status["overall_status"] in ["completed", "failed", "cancelled"]:
        break
    time.sleep(5)

if status["overall_status"] == "completed":
    links = requests.get(
        f"{BASE_URL}/workflows/runs/{job_id}/results/download-links",
        headers=headers
    ).json()
    for r in links:
        print(f"{r['filename']}: {r['download_url']}")

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

const runResponse = await fetch(
  `${BASE_URL}/workflows/run?workflow_id=${WORKFLOW_ID}`,
  {
    method: "POST",
    headers,
    body: JSON.stringify({
      webhook_payload: [
        { company_name: "Acme Corp", website: "acme.com" },
        { company_name: "TechStart", website: "techstart.io" }
      ]
    })
  }
);
if (!runResponse.ok) {
  const err = await runResponse.json();
  throw new Error(`Failed to start workflow: ${JSON.stringify(err)}`);
}
const { job_id } = await runResponse.json();

let status;
while (true) {
  const statusResponse = await fetch(
    `${BASE_URL}/workflows/runs/${job_id}/live_status`,
    { headers }
  );
  status = await statusResponse.json();
  if (["completed", "failed", "cancelled"].includes(status.overall_status)) {
    break;
  }
  await new Promise((r) => setTimeout(r, 5000));
}

if (status.overall_status === "completed") {
  const linksResponse = await fetch(
    `${BASE_URL}/workflows/runs/${job_id}/results/download-links`,
    { headers }
  );
  const links = await linksResponse.json();
  links.forEach((r) => console.log(`${r.filename}: ${r.download_url}`));
}