---
title: "Write records to destination"
method: POST
path: "/pipeline_write"
tags: ["Stateless Sync API"]
---

# Write records to destination

`POST /pipeline_write`

Reads NDJSON messages from the request body and writes them to the destination. Pipe /read output as input.

## Response `200`

NDJSON stream of write result messages

## Other responses

- `400` — Invalid params

## Changes

- **2026-04-14** `678ceced690e` — 2 info
  - added the new optional request property `oneOf[#/components/schemas/EofMessage]/eof/state`
  - added the optional property `oneOf[#/components/schemas/EofMessage]/eof/state` to the response with the `200` status
- **2026-04-14** `94093fe7df85` — 2 breaking, 6 info
  - removed `subschema #2` from the `oneOf[#/components/schemas/TraceMessage]/trace` request property `oneOf` list
  - added `subschema #2, subschema #4` to the `oneOf[#/components/schemas/TraceMessage]/trace` response property `oneOf` list for the response status `200`
  - added the new optional request property `oneOf[#/components/schemas/EofMessage]/eof/global_progress`
  - added the new optional request property `oneOf[#/components/schemas/EofMessage]/eof/stream_progress`
  - …4 more
- **2026-04-14** `c2c853a0769d` — 1 warning, 5 info
  - added the new `aborted` enum value to the `oneOf[#/components/schemas/EofMessage]/eof/reason` response property for the response status `200`
  - added the new optional request property `oneOf[#/components/schemas/EofMessage]/eof/cutoff`
  - added the new optional request property `oneOf[#/components/schemas/EofMessage]/eof/elapsed_ms`
  - added the new `aborted` enum value to the request property `oneOf[#/components/schemas/EofMessage]/eof/reason`
  - …2 more
- …earlier changes not shown

[Full history](https://skmtc.dev/stripe/apis/stripe-sync-engine/changes/pipeline_write/post.md)

---

[API](https://skmtc.dev/stripe/apis/stripe-sync-engine.md) · [All operations](https://skmtc.dev/stripe/apis/stripe-sync-engine/llms.txt) · [OpenAPI document](https://skmtc-service-production.skmtc.workers.dev/v1/apis/stripe/stripe-sync-engine/revisions/678ceced690e/schema)