# One-time status check
curl -X GET \
  "https://api.outx.ai/linkedin-agent/get-task-status?api_agent_task_id=550e8400-e29b-41d4-a716-446655440000" \
  -H "x-api-key: YOUR_API_KEY"

async function waitForTask(taskId, options = {}) {
  const { maxAttempts = 30, delayMs = 5000 } = options;

  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    const response = await fetch(
      `https://api.outx.ai/linkedin-agent/get-task-status?api_agent_task_id=${taskId}`,
      { headers: { "x-api-key": "YOUR_API_KEY" } }
    );

    const result = await response.json();

    if (result.data.status === "completed") {
      return result.data;
    }

    if (result.data.status === "failed") {
      throw new Error(`Task ${taskId} failed: ${result.data.error}`);
    }

    console.log(
      `Attempt ${attempt + 1}/${maxAttempts}: status=${result.data.status}`
    );
    await new Promise((resolve) => setTimeout(resolve, delayMs));
  }

  throw new Error(`Task ${taskId} did not complete after ${maxAttempts} attempts`);
}

// Usage
const task = await waitForTask("550e8400-e29b-41d4-a716-446655440000");
console.log("Task type:", task.task_input.task_type);
console.log("Output:", task.task_output);

import requests
import time

def wait_for_task(task_id, max_attempts=30, delay=5):
    """Poll for task completion and return the result."""
    headers = {"x-api-key": "YOUR_API_KEY"}

    for attempt in range(max_attempts):
        response = requests.get(
            "https://api.outx.ai/linkedin-agent/get-task-status",
            headers=headers,
            params={"api_agent_task_id": task_id},
        )
        result = response.json()

        if result["data"]["status"] == "completed":
            return result["data"]

        if result["data"]["status"] == "failed":
            raise RuntimeError(f"Task {task_id} failed: {result['data'].get('error')}")

        print(f"Attempt {attempt + 1}/{max_attempts}: status={result['data']['status']}")
        time.sleep(delay)

    raise TimeoutError(f"Task {task_id} did not complete after {max_attempts} attempts")

# Usage
task = wait_for_task("550e8400-e29b-41d4-a716-446655440000")
print("Task type:", task["task_input"]["task_type"])
print("Output:", task["task_output"])

{
  "success": true,
  "data": {
    "id": "550e8400-e29b-41d4-a716-446655440000",
    "status": "completed",
    "task_input": {
      "task_type": "agent_profile_fetch",
      "profile_slug": "williamhgates"
    },
    "task_output": {
      "name": "Bill Gates",
      "headline": "Co-chair, Bill & Melinda Gates Foundation"
    }
  }
}