Ingestion Pipelines

Stream logs for a pipeline run

Tail a pipeline run's logs over Server-Sent Events so a client renders them as they are produced instead of polling. Reads from whichever backend holds the run's log — object storage when streamable logs are enabled for the pipeline, the pipeline service otherwise. Every event carries an after cursor; reconnect with ?after=<cursor> to resume without re-reading what was already delivered. The server closes the stream with a complete event once the run finishes, and all viewers of the same run share a single reader against the log backend.

get/v1/services/ingestionPipelines/logs/{fqn}/stream/{runId}

Request

  • Base URL: https://demo.getcollate.io/api
  • URL: https://demo.getcollate.io/api/v1/services/ingestionPipelines/logs/{fqn}/stream/{runId}
  • Auth: HTTP bearer

Path parameters

fqnstring required

Id (UUID) or fullyQualifiedName of the ingestion pipeline

runIdstring required

Run to stream. A UUID for a run whose logs are in object storage, or the pipeline service's own run identifier.

Query parameters

afterstring

Resume the stream after this cursor, as returned by a previous event

Response

Log stream of logs, complete and error events. A deployment with no log backend, or a server at its stream capacity, answers on the stream itself with a single error event.

Changes

No recorded changes to this operation across all 1 revision of this API.