---
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-05** `db172f650b83` — 2 breaking, 4 warning, 10 info
  - removed `#/components/schemas/StateMessage` from the request body `oneOf` list
  - added `#/components/schemas/SourceStateMessage` to the response body `oneOf` list for the response status `200`
  - removed the request property `oneOf[#/components/schemas/ControlMessage]/control/config`
  - removed the request property `oneOf[#/components/schemas/ControlMessage]/control/control_type`
  - …12 more
- **2026-04-05** `42d2d829b545` — 3 breaking, 2 info
  - added the new required `header` request parameter `x-pipeline`
  - removed the media type `application/json` from the request body
  - added `#/components/schemas/StateMessage, #/components/schemas/TraceMessage, #/components/schemas/LogMessage, #/components/schemas/EofMessage` to the response body `oneOf` list for the response status `200`
  - added the media type `application/x-ndjson` to the request body
  - …1 more

[Change 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/db172f650b83/schema)