---
title: "find one dataPipelineEvent"
method: GET
path: "/api/serviceintegrations/dataPipelineEvents/{identifier}"
tags: ["dataPipelineEvents"]
---

# find one dataPipelineEvent

`GET /api/serviceintegrations/dataPipelineEvents/{identifier}`

## Request

- Base URL: `https://services.fountain.com`
- URL: `https://services.fountain.com/api/serviceintegrations/dataPipelineEvents/{identifier}`
- Auth: HTTP bearer

Find one dataPipelineEvent by its unique identifier.

## Path parameters

- `identifier` string, uuid, required

## Response `200`

One dataPipelineEvent document found. Wrapped in a JsonAPI root response with document as data.

- object
  - `data` DataPipelineEvent
    - `uuid` string, uuid, required
    - `createdAt` string, date-time
    - `createdBy` string, uuid
    - `lastUpdatedAt` string, date-time
    - `lastUpdatedBy` string, uuid
    - `lastUpdatedByAudience` string
    - `lastUpdatedByAudienceUuid` string, uuid
    - `lastUpdatedByImpersonatedBy` string, uuid
    - `lastUpdatedByCompanyUuid` string, uuid
    - `lastUpdatedByEnterpriseUuid` string, uuid
    - `companyUuid` string, uuid, required
    - `dataPipelineUuid` string, uuid, required
    - `eventType` 'import' | 'export', required
    - `status` 'pending' | 'failed' | 'succeeded' | 'completed_with_issues' | 'skipped' | 'started', required
    - `lastAttemptedAt` string, date-time
    - `failures` integer, required
    - `errorMessage` string
    - `warnings` object[]: Array of warnings encountered during import
      - `line` integer, required
      - `field` string, required
      - `message` string, required
      - `code` 'multiple' | 'unknownInternal' | 'externalLocked' | 'ineligibleOnly' | 'userNotFound' | 'userMultiple' | 'userUnavailable' | 'ownerUnlinked' | 'hireLookupFailed' | 'prospectIndexNotReady' | 'ssnKeyNotPermitted' | 'ssnSecretMissing' | 'updateNotPermitted' | 'invalidRow' | 'rowFailed' | 'batchFailed'
    - `warningCount` integer: Total count of warnings
    - `dataPipelineErrors` object[]: Array of data pipeline errors encountered during import
      - `line` integer, required
      - `field` string, required
      - `message` string
      - `reason` string
      - `kind` 'MAPPING' | 'TRANSFORM': Origin of the error. Absent on legacy entries; treat absent as MAPPING.
    - `errorCount` integer: Total count of errors
    - `kafkaEventId` string: Kafka event ID associated with this data pipeline event
    - `fileName` string, nullable: Name of the file used in the data pipeline event (null for webhook events)
    - `automationEventUuid` string, uuid: UUID of the automation event that triggered this data pipeline import.
    - `retriedFromEventUuid` string, uuid: UUID of the failed export event this run retries.
    - `retryStartedAt` string, date-time: Reservation of a failed export event for a retry. Kept when a retry creates an event.
    - `retryAttemptId` string, uuid: Owner identity of the retry reservation on this event.
    - `producedByRetryAttemptId` string, uuid: Immutable identity of the retry attempt that produced this export event.
    - `retryEventUuid` string, uuid: Resulting export event UUID, recorded after a retry creates a run.
    - `s3Key` string: S3 key of the file imported.
    - `outputFileKey` string: Object-storage key of the file produced by a non-database destination (e.g. csv export).
    - `isTest` boolean
    - `containsTaxIdentityData` boolean: Persistent sensitivity stamp for tax-form export artifacts.
    - `consentConfirmedAt` string, date-time: When the uploader confirmed consent for a prospects-type import. Together with createdBy this is the auditable consent record.
    - `optionBankDatasetUuid` string, uuid: The Option Bank an import through a pipeline with no target of its own (the standard one) fills. A retry reuses it.
    - `targetDatasetUuid` string, uuid: The dataset a datasets-pipeline import picked at import time, instead of the pipeline's own target. A retry reuses it.
    - `csvSeparator` string
    - `fileFormat` 'CSV' | 'JSON': The imported file's format when it differs from the pipeline's. Absent means the pipeline's format.
    - `csvSeparatorPending` boolean: Server-owned marker for a CSV event awaiting separator resolution. Absent on legacy events.
    - `failedRows` object[]: Rows that failed during import, stored for retry
      - `line` integer, required
      - `error` string, required
      - `code` 'multiple' | 'unknownInternal' | 'externalLocked' | 'ineligibleOnly' | 'userNotFound' | 'userMultiple' | 'userUnavailable' | 'ownerUnlinked' | 'hireLookupFailed' | 'prospectIndexNotReady' | 'ssnKeyNotPermitted' | 'ssnSecretMissing' | 'updateNotPermitted' | 'invalidRow' | 'rowFailed' | 'batchFailed'
      - `data` object: Original row data (optional)
      - `recordId` string: Export runs: the source record's uuid (WX) or id (Hire applicant). Absent on import rows.
    - `importStats` object: Import statistics
      - `totalRows` integer
      - `successCount` integer
      - `failureCount` integer
      - `failureCodes` object
      - `warningCodes` object
      - `createCount` integer
      - `updateCount` integer
      - `invitedCount` integer: Applicant imports only: rows Hire's arrival invitation actually fired for.
      - `rowsRead` integer: Streamed imports only: rows read from the file so far. Equals totalRows once the whole file is read.
    - `processedBatches` integer: Number of batches processed so far
    - `totalBatches` integer: Total number of batches expected
    - `pacing` object: Set on a paced import: each minute it reads the next slice of its file, so that at most batchesPerMinute of its batches await an ACK. active turns false once the file is read or the event reaches a final status.
      - `active` boolean
      - `dataType` string
      - `batchesPerMinute` integer
      - `byteOffset` integer
      - `nextLine` integer
      - `nextBatchIndex` integer
      - `canUpdateEmployers` boolean
      - `employerFieldGrants` string[]
      - `canUseSsnKey` boolean
    - `transformStats` object[]: Per-target-field stats from the Transform step. Entries are appended per batch; consumers fold by targetField.
      - `targetField` string, required
      - `executionMs` integer, required
      - `errorCount` integer, required
      - `skipCount` integer, required
  - `meta` ResponsesPartMeta
    - `timestamp` string, date-time, required
    - `verb` 'OPTION' | 'GET' | 'PUT' | 'POST' | 'PATCH' | 'DELETE'
    - `path` string
    - `jti` string
    - `rid` string
    - `count` number
    - `capped` boolean: The server lowered filter[limit] to its ceiling. Page with filter[skip] to read past it.
    - `status` string
    - `duration` number
    - `size` number

## Other responses

- `500`: default error response

---

[API](https://skmtc.dev/fountain/apis/worker-experience-public-api.md) - [All operations](https://skmtc.dev/fountain/apis/worker-experience-public-api/llms.txt) - [OpenAPI document](https://skmtc.dev/fountain/apis/worker-experience-public-api/revisions/6b9a31f79e22?raw)