curl "https://api.u1.archetypeai.app/v0.5/batch/jobs/job_2abc3def4ghi5jkl6mno7pqr/inputs/progress?status=processing&status=pending&order=desc&limit=20" \
  -H "Authorization: Bearer $ATAI_API_KEY"

import requests
import os

api_key = os.environ.get("ATAI_API_KEY")
job_id = "job_2abc3def4ghi5jkl6mno7pqr"

response = requests.get(
    f"https://api.u1.archetypeai.app/v0.5/batch/jobs/{job_id}/inputs/progress",
    headers={"Authorization": f"Bearer {api_key}"},
    params=[
        ("status", "processing"),
        ("status", "pending"),
        ("order", "desc"),
        ("limit", 20),
    ],
)

data = response.json()
for item in data["data"]:
    inp = item["input"]
    progress = item.get("latest_progress")
    pct = progress["metrics"].get("percent_complete") if progress else None
    print(f"  {inp['id']} [{inp['status']}] step={item.get('step')} progress={pct}")

# Pass the cursor back verbatim as `after` to fetch the next page.
if data["has_more"]:
    print(f"Next page cursor: {data['next_cursor']}")

const jobId = 'job_2abc3def4ghi5jkl6mno7pqr';
const params = new URLSearchParams();
params.append('status', 'processing');
params.append('status', 'pending');
params.append('order', 'desc');
params.append('limit', '20');

const response = await fetch(`https://api.u1.archetypeai.app/v0.5/batch/jobs/${jobId}/inputs/progress?${params}`, {
  headers: { 'Authorization': `Bearer ${process.env.ATAI_API_KEY}` }
});

const data = await response.json();
data.data.forEach(({ input, latest_progress, step }) => {
  const pct = latest_progress?.metrics?.percent_complete ?? null;
  console.log(`  ${input.id} [${input.status}] step=${step} progress=${pct}`);
});

if (data.has_more) {
  console.log(`Next page cursor: ${data.next_cursor}`);
}

{
  "job_id": "job_2abc3def4ghi5jkl6mno7pqr",
  "data": [
    {
      "input": {
        "id": "inp_abc123def456",
        "job_id": "job_2abc3def4ghi5jkl6mno7pqr",
        "port_name": "worker.inference",
        "file_id": "file_abc123",
        "data": {
          "ref": "https://storage.example.com/files/tep_inference.csv",
          "filename": "tep_inference.csv",
          "file_type": "text/csv",
          "file_extension": ".csv",
          "num_bytes": 245760,
          "metadata": {}
        },
        "status": "processing",
        "error_message": null,
        "created_at": "2026-04-14T10:00:00Z",
        "completed_at": null
      },
      "latest_progress": {
        "id": 502,
        "kind": "inference",
        "step": 5,
        "metrics": {
          "percent_complete": 50,
          "items_processed": 5,
          "items_total": 10
        },
        "payload": {},
        "input_id": "inp_abc123def456",
        "index": 0,
        "message": "Processing input 5 of 10",
        "created_at": "2026-04-14T10:06:00Z"
      },
      "step": null
    }
  ],
  "has_more": true,
  "next_cursor": "<opaque-cursor>",
  "prev_cursor": null
}

{
  "code": "...",
  "message": "...",
  "error_uid": "err_abc123"
}

{
  "code": "NOT_FOUND",
  "message": "Job not found",
  "error_uid": "err_abc123"
}

{
  "detail": "Invalid access with key: api_key_not_found"
}