Skip to main content

Get stream state

GET 
/v1/delta/streams/:connector/:stream

Returns the row from delta_stream_state for this stream, or a synthetic status: 'idle' payload if no row exists yet — callers can treat both cases identically.

Use this before begin if you care about concurrency. The API itself will happily accept a new begin on top of a row that's already running; the consumer decides whether to skip, override based on age, or fail loudly. Typical pattern:

const s = GET /delta/streams/erp/invoices
if (s.status === 'running') {
  const ageMin = (Date.now() - new Date(s.started_at_utc)) / 60000;
  if (ageMin < 60) return; // skip — earlier run still active
  // else fall through to begin (override stuck run)
}

Request​

Responses​

Stream state