---
title: "Get Latest Source Execution"
method: GET
path: "/api/sequences/{sequence_id}/sources/{source_node_id}/latest"
tags: ["sequences"]
---

# Get Latest Source Execution

`GET /api/sequences/{sequence_id}/sources/{source_node_id}/latest`

## Request

- Base URL: `https://platform.verbiflow.com/api/bridge`
- URL: `https://platform.verbiflow.com/api/bridge/api/sequences/{sequence_id}/sources/{source_node_id}/latest`
- Auth: one of:
  - HTTP bearer and API key in header `x-flage-org-id`
  - HTTP bearer and API key in header `x-flage-org-slug`

Return the latest source execution for legacy non-staging consumers.

Returns the most-recent source_execution row for (org, sequence,
source_node), plus its accumulated rows from the dynamic table if
one exists.

`config_hash` (optional) filters to runs whose filter combination
matches the supplied signature, so toggling between filter sets
re-surfaces each set's last run instead of always showing the most
recent overall.

`has_execution=False` when no run matches the filters.

## Path parameters

- `sequence_id` string, required
- `source_node_id` string, required

## Query parameters

- `ingress_id` string, nullable: Filter to one ingress within the audience node
- `config_hash` string, nullable: Filter to runs that match this filter signature

## Response `200`

Successful Response

- SourceExecutionLatestPayload: Latest durable execution snapshot for one campaign source.
  - `config_hash` string, nullable: Digest of the exact source config executed.
  - `counts` CampaignSourceCounts: Source progress counters. Provider-specific counters remain extensions; preview credits can be zero.
    - `available_total` integer: Current total rows available for review.
    - `company` integer: Companies produced by the source pipeline.
    - `contact` integer: Contacts produced by the source pipeline.
    - `contact_count` integer: Contacts currently available in staging.
    - `credit_units` string: Exact Decimal credits as a string; sample previews report zero.
    - `row_count` integer: Rows currently available in staging.
  - `ended_at` string, date-time, nullable: Time when source execution terminalized.
  - `error_message` string, nullable: Sanitized terminal execution error.
  - `has_execution` boolean, required: Whether this source has any execution snapshot.
  - `ingress_id` string, nullable: Operational source ingress id.
  - `mode` 'sample' | 'full', nullable: Preview or production source execution mode.
  - `rows` SourceExecutionRowPayload[]: Bounded normalized preview rows.
    - `row_identifier` string, required: Stable source-level identity used for adoption and deduplication.
    - `row_value` object, required: Provider-normalized row payload.
    - `source_run_row_id` string, required: Stable row id within the source execution.
    - `step_name` string, required: Source pipeline step that emitted the row.
  - `sequence_id` string, required: Campaign that owns the source.
  - `source_kind` string, nullable: Source adapter used by the execution.
  - `source_node_id` string, required: Workflow source node that owns the ingress.
  - `source_run_id` string, nullable: Latest immutable source execution id.
  - `started_at` string, date-time, nullable: Time when source execution started.
  - `status` 'pending' | 'running' | 'completed' | 'failed', nullable: Current source execution state.
  - `workflow_id` string, nullable: Durable workflow id.
  - `workflow_run_id` string, nullable: Durable workflow run id.

## Other responses

- `422`: Validation Error

---

[API](https://skmtc.dev/verbiflow/apis/verbiflow-sdk-http-contract.md) - [All operations](https://skmtc.dev/verbiflow/apis/verbiflow-sdk-http-contract/llms.txt) - [OpenAPI document](https://skmtc.dev/verbiflow/apis/verbiflow-sdk-http-contract/revisions/c80e903ef8f3?raw)