Releasesv0.1.0
Api referenceEndpointsPipeline

Processing jobs of the tenant

GET
/v1/pipeline/etl-jobs

The jobs that turn stored raw payloads into records, newest first. parked (the default) lists the jobs that failed 5 times and wait for a retry; pending and running list the work in flight. Done jobs are summed up by each user's coverage report.

Authorization

tenantKey
headerAuthorizationBearer <token>

Tenant API key, ohs_sk_ + 43 base62 characters.

Query Parameters

status?string
Default"parked"
Value in"parked""pending""running"
provider?string

Only this provider's jobs.

limit?integer
Range1 <= value <= 100
Default50
cursor?string

The next_cursor of the previous page.

Header Parameters

Authorization*string

The tenant API key, as a bearer secret.

Response Body

A page of jobs.

application/json
  1. response
data*array<>
next_cursor*|

Null on the last page.

curl -X GET 'http://localhost:8080/v1/pipeline/etl-jobs' \  -H 'Authorization: Bearer ohs_sk_...'
{  "next_cursor": "string",  "data": [    {      "id": 0,      "user_id": "a169451c-8525-4352-b8ca-070dd449a1a5",      "provider": "string",      "tier": "string",      "status": "pending",      "attempts": 0,      "error": "string",      "created_at": "2019-08-24T14:15:22Z",      "next_attempt_at": "2019-08-24T14:15:22Z"    }  ]}
Edit on GitHub