A run is one execution of a pipeline graph. Use these endpoints to audit outcomes, drill into per-node metrics, stream logs, and cancel work.
Base URL: https://api.planasonix.comAuth: Authorization: Bearer plus your API key or JWT.GET /api/runsList runs across pipelines with filters.
Only runs for this pipeline.
queued, running, succeeded, failed, canceled, and so on.
Encoded range (for example 2025-03-01..2025-03-31) or separate from/to if your deployment exposes them.
{ "data" : [ { "id" : "run_01j8k2m4" , "pipelineId" : "pl_02hqabc" , "status" : "succeeded" , "trigger" : "schedule" , "startedAt" : "2025-03-27T02:00:00Z" , "finishedAt" : "2025-03-27T02:18:42Z" , "durationSeconds" : 1122 }, { "id" : "run_01j7j1k2" , "pipelineId" : "pl_02hqabc" , "status" : "failed" , "trigger" : "manual" , "startedAt" : "2025-03-26T14:12:00Z" , "finishedAt" : "2025-03-26T14:14:05Z" , "durationSeconds" : 125 } ], "meta" : { "cursor" : "eyJpZCI6InJ1bl8wMWo3ajFrMiJ9" } }
GET /api/runs/{id}Full run record: status, timing, row counts, errors, and trigger metadata.
Terminal or in-progress state.
Aggregated counters (rows read/written, bytes, cost units).
Present when status is failed; includes message and optional stack reference.
{ "id" : "run_01j8k2m4" , "pipelineId" : "pl_02hqabc" , "pipelineName" : "crm_to_warehouse" , "status" : "succeeded" , "trigger" : { "type" : "schedule" , "scheduleId" : "sch_01" }, "startedAt" : "2025-03-27T02:00:00Z" , "finishedAt" : "2025-03-27T02:18:42Z" , "durationSeconds" : 1122 , "metrics" : { "rowsRead" : 2450000 , "rowsWritten" : 2450000 , "bytesShuffled" : 1073741824 }, "error" : null }
GET /api/runs/{id}/nodesPer-node execution: start/finish times, state, retries, and row counts.
{ "runId" : "run_01j8k2m4" , "nodes" : [ { "nodeId" : "n_source" , "type" : "source.postgres" , "status" : "succeeded" , "startedAt" : "2025-03-27T02:00:05Z" , "finishedAt" : "2025-03-27T02:04:10Z" , "metrics" : { "rowsOut" : 2450000 } }, { "nodeId" : "n_sink" , "type" : "destination.snowflake" , "status" : "succeeded" , "startedAt" : "2025-03-27T02:04:12Z" , "finishedAt" : "2025-03-27T02:18:40Z" , "metrics" : { "rowsIn" : 2450000 } } ] }
GET /api/runs/{id}/logsExecution logs (plain text chunks, JSON lines, or URLs to object storage, depending on deployment).
Filter to a single node’s log stream.
ISO timestamp or log cursor for incremental fetch.
Show Example response (structured lines)
{ "runId" : "run_01j8k2m4" , "lines" : [ { "ts" : "2025-03-27T02:00:06Z" , "level" : "info" , "nodeId" : "n_source" , "message" : "Started JDBC read" }, { "ts" : "2025-03-27T02:04:09Z" , "level" : "info" , "nodeId" : "n_source" , "message" : "Read completed: 2450000 rows" } ], "nextCursor" : "crs_01j8k2m4_0042" }
DELETE /api/runs/{id}Request cancellation of a running or queued run. Completed runs return 409 or 400 depending on policy.
Show Example request and response
curl -X DELETE https://api.planasonix.com/api/runs/run_01j9l3n5 \ -H "Authorization: Bearer plnx_live_xxxxxxxx"
Status reference Status Meaning queuedScheduled or manual run waiting for capacity runningActively executing succeededAll nodes completed without fatal errors failedOne or more nodes failed or policy aborted the run canceledUser or system canceled the run
Trigger a run POST /api/pipelines/{id}/run
Run history (UI) How runs appear in the product.
