Pipeline

Pipeline status

get

Composite pipeline dashboard: connector-runner state + Lakebase counts.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

Responses

200

Successful Response

application/json

statusstringRequired

connector_runner_statusstringRequired

uptime_secondsinteger · nullableOptional

active_pollsintegerOptionalDefault: 0

total_eventsinteger · nullableOptional

Read-model event count for the last 7 days. Null means the read model is empty or unavailable; zero means the read model is ready and has no events.

event_read_model_statusstring · enumOptionalDefault: emptyPossible values:

event_read_model_synced_atstring · date-time · nullableOptional

total_entitiesintegerOptionalDefault: 0

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/status

GET /v1/{workspace_id}/pipeline/status HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "status": "text",
  "connector_runner_status": "text",
  "uptime_seconds": 1,
  "active_polls": 0,
  "total_events": 1,
  "event_read_model_status": "empty",
  "event_read_model_synced_at": "2026-01-01T00:00:00.000Z",
  "total_entities": 0,
  "sources": [
    {
      "data_source_id": "123e4567-e89b-12d3-a456-426614174000",
      "workspace_id": "123e4567-e89b-12d3-a456-426614174000",
      "source_type": "ehr",
      "connector_type": "text",
      "status": "text",
      "last_poll_at": "text",
      "last_poll_duration_ms": 0,
      "last_poll_event_count": 0,
      "last_error": "text",
      "consecutive_errors": 0,
      "connection_healthy": true
    }
  ],
  "entity_resolution": {
    "ANY_ADDITIONAL_PROPERTY": "anything"
  },
  "review_loop": {
    "ANY_ADDITIONAL_PROPERTY": "anything"
  },
  "outbound_dispatch": {
    "ANY_ADDITIONAL_PROPERTY": "anything"
  },
  "outbound_subscriber": {
    "ANY_ADDITIONAL_PROPERTY": "anything"
  },
  "reconciliation": {
    "ANY_ADDITIONAL_PROPERTY": "anything"
  },
  "gap_scanner": {
    "ANY_ADDITIONAL_PROPERTY": "anything"
  }
}

List pipeline sources

get

Data sources with live health from Valkey cr:last_poll keys.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

Query parameters

searchstring · nullableOptional

Search by name, ID, type, or health status

source_typestring · nullableOptional

Filter by source type

health_statusstring · nullableOptional

Filter by health status

is_activeboolean · nullableOptional

Filter by active state

Responses

200

Successful Response

application/json

idstring · uuidRequired

namestringRequired

display_namestring · nullableOptional

source_typestring · enumRequiredPossible values:

is_activebooleanRequired

health_statusstring · enumRequiredPossible values:

event_countintegerOptionalDefault: 0

last_sync_atstring · nullableOptional

422

Validation Error

application/json

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/sources

GET /v1/{workspace_id}/pipeline/sources HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

[
  {
    "id": "123e4567-e89b-12d3-a456-426614174000",
    "name": "text",
    "display_name": "text",
    "source_type": "ehr",
    "is_active": true,
    "health_status": "unknown",
    "last_poll": {
      "at": "text",
      "duration_ms": 0,
      "event_count": 0,
      "error": "text"
    },
    "event_count": 0,
    "last_sync_at": "text"
  }
]

Source overview

get

Consolidated source detail: metadata, health, recent failures, last poll, outbound summary.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

source_idstring · uuidRequired

Responses

200

Successful Response

application/json

idstring · uuidRequired

namestringRequired

display_namestring · nullableOptional

source_typestring · enumRequiredPossible values:

is_activebooleanRequired

health_statusstring · enumRequiredPossible values:

last_sync_atstring · nullableOptional

last_sync_statusstring · enum · nullableOptionalPossible values:

last_sync_event_countintegerOptionalDefault: 0

created_atstring · nullableOptional

event_countintegerOptionalDefault: 0

entity_countintegerOptionalDefault: 0

404

Data source not found

422

Validation Error

application/json

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/sources/{source_id}/overview

GET /v1/{workspace_id}/pipeline/sources/{source_id}/overview HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "id": "123e4567-e89b-12d3-a456-426614174000",
  "name": "text",
  "display_name": "text",
  "source_type": "ehr",
  "is_active": true,
  "health_status": "unknown",
  "last_sync_at": "text",
  "last_sync_status": "success",
  "last_sync_event_count": 0,
  "created_at": "text",
  "event_count": 0,
  "entity_count": 0,
  "last_poll": {
    "at": "text",
    "duration_ms": 0,
    "event_count": 0,
    "error": "text"
  },
  "recent_failures": [
    {
      "event_id": "123e4567-e89b-12d3-a456-426614174000",
      "event_type": "text",
      "fhir_resource_type": "text",
      "sync_error": "text",
      "ingested_at": "text"
    }
  ],
  "outbound": {
    "total": 0,
    "synced": 0,
    "failed": 0,
    "pending": 0,
    "last_synced_at": "text"
  }
}

Source sync history

get

Event counts bucketed by time window for a specific source.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

source_idstring · uuidRequired

Query parameters

date_fromstring · date-time · nullableOptional

date_tostring · date-time · nullableOptional

intervalstring · enumOptionalDefault: 1hPossible values:

hoursinteger · min: 1 · max: 720 · nullableOptional

Responses

200

Successful Response

application/json

bucketstringRequired

source_systemstring · nullableOptional

event_countintegerRequired

422

Validation Error

application/json

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/sources/{source_id}/history

GET /v1/{workspace_id}/pipeline/sources/{source_id}/history HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

[
  {
    "bucket": "text",
    "source_system": "text",
    "event_count": 1
  }
]

Source events

get

Paginated events for a specific data source.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

source_idstring · uuidRequired

Query parameters

sort_bystring[]OptionalDefault: []

limitinteger · max: 200OptionalDefault: 50

continuation_tokenanyOptional

event_typestring · nullableOptional

Filter by event type

entity_typestring · nullableOptional

Filter by entity type

date_fromstring · date-time · nullableOptional

Filter events ingested on or after this time

date_tostring · date-time · nullableOptional

Filter events ingested on or before this time

Responses

200

Successful Response

application/json

has_morebooleanRequired

continuation_tokenanyOptional

422

Validation Error

application/json

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/sources/{source_id}/events

GET /v1/{workspace_id}/pipeline/sources/{source_id}/events HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "items": [
    {
      "id": "123e4567-e89b-12d3-a456-426614174000",
      "event_type": "text",
      "entity_type": "text",
      "entity_id": "123e4567-e89b-12d3-a456-426614174000",
      "source": "text",
      "source_system": "text",
      "confidence": 1,
      "ingested_at": "2026-01-01T00:00:00.000Z"
    }
  ],
  "has_more": true,
  "continuation_token": null
}

Outbound sync summary

get

Per-sink outbound sync aggregation: synced/failed/pending counts.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

Responses

200

Successful Response

application/json

data_source_idstring · uuidRequired

data_source_namestringRequired

totalintegerRequired

syncedintegerRequired

failedintegerRequired

pendingintegerRequired

last_synced_atstring · nullableOptional

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/outbound

GET /v1/{workspace_id}/pipeline/outbound HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

[
  {
    "data_source_id": "123e4567-e89b-12d3-a456-426614174000",
    "data_source_name": "text",
    "total": 1,
    "synced": 1,
    "failed": 1,
    "pending": 1,
    "last_synced_at": "text"
  }
]

Outbound sync log

get

Paginated outbound sync log for a specific sink.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

data_source_idstring · uuidRequired

Query parameters

limitinteger · max: 200OptionalDefault: 50

continuation_tokenanyOptional

statusstring · enum · nullableOptionalPossible values:

Responses

200

Successful Response

application/json

has_morebooleanRequired

continuation_tokenanyOptional

422

Validation Error

application/json

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/outbound/{data_source_id}/log

GET /v1/{workspace_id}/pipeline/outbound/{data_source_id}/log HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "items": [
    {
      "id": "123e4567-e89b-12d3-a456-426614174000",
      "event_id": "123e4567-e89b-12d3-a456-426614174000",
      "synced_at": "2026-01-01T00:00:00.000Z",
      "sync_error": "text",
      "attempt_count": 1,
      "created_at": "2026-01-01T00:00:00.000Z"
    }
  ],
  "has_more": true,
  "continuation_token": null
}

Entity resolution metrics

get

Historical same_as merge-edge counts (written by the pre-SDP resolver; merge detection now lives in the Databricks pipeline — new edges are not produced) and entity resolution loop status.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

Responses

200

Successful Response

application/json

total_same_as_edgesintegerRequired

recent_merges_24hintegerRequired

loop_statusstringRequired

last_tick_atstring · nullableOptional

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/entity-resolution

GET /v1/{workspace_id}/pipeline/entity-resolution HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "total_same_as_edges": 1,
  "recent_merges_24h": 1,
  "loop_status": "text",
  "last_tick_at": "text"
}

Review pipeline metrics

get

Review queue depth, approval rate, and average review time.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

Responses

200

Successful Response

application/json

queue_depthintegerRequired

approved_7dintegerRequired

rejected_7dintegerRequired

avg_review_time_hoursnumber · nullableOptional

total_itemsintegerOptionalDefault: 0

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/review

GET /v1/{workspace_id}/pipeline/review HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

{
  "queue_depth": 1,
  "pending_by_priority": {
    "ANY_ADDITIONAL_PROPERTY": 1
  },
  "approved_7d": 1,
  "rejected_7d": 1,
  "avg_review_time_hours": 1,
  "total_items": 0
}

Event throughput

get

Event throughput time series across all sources.

Authorizations

AuthorizationstringRequired

API key issued via POST /v1/{workspace_id}/api-keys. Pass the returned api_key value as a Bearer token.

Path parameters

workspace_idstring · uuidRequired

Query parameters

date_fromstring · date-time · nullableOptional

date_tostring · date-time · nullableOptional

intervalstring · enumOptionalDefault: 1dPossible values:

hoursinteger · min: 1 · max: 720 · nullableOptional

bucket_minutesinteger · min: 1 · max: 1440 · nullableOptional

Responses

200

Successful Response

application/json

bucketstringRequired

source_systemstring · nullableOptional

event_countintegerRequired

422

Validation Error

application/json

429

Rate limit exceeded

get/v1/{workspace_id}/pipeline/throughput

GET /v1/{workspace_id}/pipeline/throughput HTTP/1.1
Host: api.platform.amigo.ai
Authorization: Bearer YOUR_SECRET_TOKEN
Accept: */*

[
  {
    "bucket": "text",
    "source_system": "text",
    "event_count": 1
  }
]

PreviousData Query NextAnalytics

Last updated 1 day ago

Was this helpful?