Pipeline Runs

{
  "status": "running",
  "totalRows": 50000,
  "processedRows": 32000,
  "failedRows": 12,
  "skippedRows": 3,
  "partitions": 4,
  "completedPartitions": 2,
  "partitionDetails": [
    { "index": 0, "status": "completed", "rows": 12500 },
    { "index": 1, "status": "completed", "rows": 12500 },
    { "index": 2, "status": "running", "rows": 7000, "progress": 56 },
    { "index": 3, "status": "pending", "rows": 0 }
  ],
  "validationErrors": [
    { "row": 142, "column": "email", "value": "not-an-email", "error": "Invalid email format" }
  ],
  "eta": "3m",
  "durationMs": 45200,
  "loadStrategy": "upsert",
  "log": [
    { "stage": "extract", "message": "Read 50000 rows from source", "timestamp": "2026-03-30T10:00:05Z" }
  ]
}

{
  "runId": "run_001",
  "total": 12,
  "errors": [
    { "row": 142, "column": "email", "value": "not-an-email", "error": "Invalid email format" },
    { "row": 305, "column": "age", "value": "abc", "error": "Expected integer" }
  ]
}

Content-Type: text/csv; charset=utf-8
Content-Disposition: attachment; filename="pipeline-run-{runId}-errors.csv"

{
  "title": "Retry endpoint deprecated",
  "detail": "Pipeline {id}, run {runId}: legacy retry-with-checkpoint was removed on 2026-04-28. To re-run an IR-native pipeline, POST /api/v1/pipelines/{id}/run again."
}

{
  "runId": "run_001",
  "nodeId": "validate_email",
  "quarantineTable": "public._flow_dlq_validate_email",
  "count": 2,
  "rows": [
    { "id": "1", "ruleId": "email_regex", "row": { "email": "not-an-email" }, "createdAt": "2026-03-30T10:00:05Z" }
  ]
}