Read task results by page

curl "https://api.reversecontact.com/v2/tasks/7b1e4c2a-5d3f-4e8b-9a6c-1f2d3e4b5a60/rows?limit=100" \
  -H "Authorization: Bearer YOUR_API_KEY"

const taskId = "7b1e4c2a-5d3f-4e8b-9a6c-1f2d3e4b5a60";
const headers = { "Authorization": "Bearer YOUR_API_KEY" };
const sleep = (seconds) => new Promise((resolve) => setTimeout(resolve, seconds * 1000));

let cursor = null;
do {
  const query = new URLSearchParams({ limit: "100", ...(cursor ? { cursor } : {}) });
  const response = await fetch(`https://api.reversecontact.com/v2/tasks/${taskId}/rows?${query}`, { headers });
  if (response.status === 429) {
    await sleep(Number(response.headers.get("retry-after") ?? 2));
    continue;
  }
  const { data } = await response.json();
  for (const item of data.items) console.log(item.row, item.input.externalId, item.status);
  if (data.items.length === 0 && data.nextCursor) {
    if (data.status === "paused") break;
    await sleep(Number(response.headers.get("retry-after") ?? 2));
  }
  cursor = data.nextCursor;
} while (cursor);

import time

import requests

task_id = "7b1e4c2a-5d3f-4e8b-9a6c-1f2d3e4b5a60"
headers = {"Authorization": "Bearer YOUR_API_KEY"}

cursor = None
while True:
    params = {"limit": 100, **({"cursor": cursor} if cursor else {})}
    response = requests.get(
        f"https://api.reversecontact.com/v2/tasks/{task_id}/rows", headers=headers, params=params
    )
    if response.status_code == 429:
        time.sleep(int(response.headers.get("Retry-After", 2)))
        continue
    data = response.json()["data"]
    for item in data["items"]:
        print(item["row"], item["input"].get("externalId"), item["status"])
    if not data["items"] and data["nextCursor"]:
        if data["status"] == "paused":
            break
        time.sleep(int(response.headers.get("Retry-After", 2)))
    cursor = data["nextCursor"]
    if cursor is None:
        break

{
  "success": true,
  "data": {
    "items": [
      {
        "row": 1,
        "input": { "linkedinUrl": "https://www.social.com/in/janedoe", "externalId": "crm-001" },
        "status": "enriched",
        "message": "Profile and email found (4 credits)",
        "creditsConsumed": 4,
        "person": {
          "id": "prs_9f8e7d6c5b4a",
          "firstName": "Jane",
          "lastName": "Doe",
          "linkedinUrl": "https://www.social.com/in/janedoe",
          "headline": "VP of Marketing @ Acme Corp"
        },
        "isFullProfile": true,
        "contactEmail": { "status": "found", "value": "jane.doe@acme.com", "personalValue": null }
      },
      {
        "row": 2,
        "input": { "firstName": "John", "lastName": "Smith", "companyDomain": "acme.com", "externalId": "crm-002" },
        "status": "partial",
        "message": "Profile found, no email (2 credits)",
        "creditsConsumed": 2,
        "person": {
          "id": "prs_1a2b3c4d5e6f",
          "firstName": "John",
          "lastName": "Smith",
          "linkedinUrl": "https://www.social.com/in/john-smith",
          "headline": "Head of Sales at Acme"
        },
        "isFullProfile": true,
        "contactEmail": { "status": "not_found", "value": null, "personalValue": null }
      }
    ],
    "nextCursor": "eyJ2IjoxLCJyb3ciOjN9",
    "status": "running"
  },
  "error": null,
  "quotas": {
    "creditsConsumed": 0,
    "workspace": {
      "id": "ws_abc123",
      "credits": { "total": 10000, "used": 4531, "left": 5469 }
    }
  },
  "metadata": {
    "requestId": "41f7ce39-14eb-4f81-a499-bcbd97d437ed",
    "executionTimeMs": 42
  }
}

{
  "success": true,
  "data": {
    "items": [],
    "nextCursor": "eyJ2IjoxLCJyb3ciOjN9",
    "status": "running"
  },
  "error": null,
  "quotas": {
    "creditsConsumed": 0,
    "workspace": {
      "id": "ws_abc123",
      "credits": { "total": 10000, "used": 4531, "left": 5469 }
    }
  },
  "metadata": {
    "requestId": "6f4a5cba-ef9e-470b-ab60-821d4781673c",
    "executionTimeMs": 18
  }
}

{
  "success": false,
  "data": null,
  "error": {
    "code": "TASK_ROWS_BUSY",
    "message": "Too many result pages read at once: retry in 2 seconds",
    "details": { "retryAfter": 2 }
  },
  "quotas": {
    "creditsConsumed": 0,
    "workspace": {
      "id": "ws_abc123",
      "credits": { "total": 10000, "used": 4531, "left": 5469 }
    }
  },
  "metadata": {
    "requestId": "def7c408-4e1c-4b83-8858-8e87de88925a",
    "executionTimeMs": 3
  }
}