Submit an async intelligence job | KINETK Graph Service API

curl -X POST https://api.kinetk.ai/graph/intelligence/jobs \
     -H "x-api-key: <apiKey>" \
     -H "Content-Type: application/json" \
     -d '{
  "kind": "insights",
  "input": {
    "limit": 1.1,
    "query": "string",
    "window": "30d"
  }
}'

{
  "jobId": "string",
  "status": "failed",
  "dedup": true,
  "fromCache": true,
  "result": {
    "content": [
      {
        "authorReach": 1.1,
        "commentCount": 1.1,
        "contentType": "string",
        "creatorId": 1.1,
        "description": "string",
        "engagementDepth": 1.1,
        "engagementScore": 1.1,
        "enrichment": {
          "aestheticStyle": [
            "string"
          ],
          "attributeConfidence": 1.1,
          "brandProducts": [
            "string"
          ],
          "coverage": {
            "attributes": true,
            "novelty": true,
            "sentiment": true
          },
          "emotionMood": [
            "string"
          ],
          "noveltyScore": 1.1,
          "saturationScore": 1.1,
          "themes": [
            "string"
          ],
          "tone": "string",
          "toneConfidence": 1.1
        },
        "exampleRankingScore": 1.1,
        "followerCount": 1.1,
        "likeCount": 1.1,
        "platform": "string",
        "publishedAt": "string",
        "rawSimilarity": 1.1,
        "recencyScore": 1.1,
        "relevance": 1.1,
        "rrfScore": 1.1,
        "shareCount": 1.1,
        "similarity": 1.1,
        "subjectMatch": true,
        "tags": [
          "string"
        ],
        "textRerankScore": 1.1,
        "title": "string",
        "uuid": "string",
        "viewCount": 1.1
      }
    ],
    "generatedAt": "string",
    "graph": {
      "edges": [
        {
          "source": "string",
          "target": "string",
          "type": "contains",
          "weight": 1.1
        }
      ],
      "nodes": [
        {
          "creatorId": 1.1,
          "id": "string",
          "label": "string",
          "score": 1.1,
          "type": "content"
        }
      ]
    },
    "query": "string",
    "type": "kinetk.query_intelligence.record.v1",
    "window": "30d"
  },
  "resultBytes": 1.1,
  "resultExpiresAt": "string",
  "resultStorage": "s3",
  "resultUrl": "string",
  "statusUrl": "string"
}

Submit a job for async execution. Request body is { kind, input } discriminated by kind.

Response shapes:

200 + { fromCache: true, result, charged } — identical recent job within the per-kind freshness window; cached result returned synchronously and charged at full rate (no cache discount).
202 + { dedup: true } — identical job currently queued/running; reuses the in-flight jobId.
202 + { estimated_cost } — new job accepted; the credits were reserved at the estimate. Poll GET /intelligence/jobs/{id}.
402 — insufficient credits; body recommends how to fit your budget.

For records / insights, window (in input) is REQUIRED — it drives the credit price (fresher windows cost more). estimated_cost is an upper bound; the final charge is computed from the records actually returned.

Input validation is strict: any undeclared field, type mismatch, or out-of-enum value is rejected with 400 (nothing is silently stripped or coerced).

Submit a job for async execution. Request body is `{ kind, input }` discriminated by `kind`. Response shapes: - `200 + { fromCache: true, result, charged }` — identical recent job within the per-kind freshness window; cached result returned synchronously and charged at full rate (no cache discount). - `202 + { dedup: true }` — identical job currently queued/running; reuses the in-flight `jobId`. - `202 + { estimated_cost }` — new job accepted; the credits were reserved at the estimate. Poll `GET /intelligence/jobs/{id}`. - `402` — insufficient credits; body recommends how to fit your budget. For `records` / `insights`, `window` (in `input`) is REQUIRED — it drives the credit price (fresher windows cost more). `estimated_cost` is an upper bound; the final charge is computed from the records actually returned. Input validation is strict: any undeclared field, type mismatch, or out-of-enum value is rejected with `400` (nothing is silently stripped or coerced).

Authentication

x-api-keystring

Customer secret key, required on every request. Validated natively by API Gateway; missing / invalid / revoked → 403.

Request

This endpoint expects an object.

insightsobjectRequired

recordsobjectRequired

Response headers

X-Kinetk-Credits-Useddouble

Credits consumed by this call (reserved estimate on a 202; actual once settled).

X-Kinetk-Credits-Remainingdouble

Account credit balance remaining after this call.

Response

Successful response

jobIdstring

statusenum

dedupboolean

fromCacheboolean

resultobject

resultBytesdouble

Size of the stored result in bytes (present alongside resultUrl).

resultExpiresAtstring

ISO-8601 expiry of resultUrl (clamped to the job’s own retention).

resultStorageenum

Set to “s3” when the result was too large to return inline; in that case result is omitted and resultUrl holds a short-lived presigned download URL instead. Fetch the URL directly; re-poll for a fresh one after it expires (see resultExpiresAt).

resultUrlstring

Short-lived presigned GET URL for a large result (present iff resultStorage === “s3”).

statusUrlstring

Errors

402

Payment Required Error