---
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-27** `399c9fa011ec` — 1 breaking
  - the request property `oneOf[#/components/schemas/CatalogMessage]/catalog/streams/items/newer_than_field` became required
- **2026-04-23** `32948b4a64a1` — 1 info
  - added the new optional request property `oneOf[#/components/schemas/SpecMessage]/spec/soft_limit_fraction`
- **2026-04-21** `d5eaf6622a23` — 2 info
  - the request property `oneOf[#/components/schemas/ControlMessage]/control/oneOf[subschema #2]/destination_config/oneOf[#/components/schemas/DestinationGoogleSheetsConfig]/access_token` became optional
  - request property `oneOf[#/components/schemas/ControlMessage]/control/oneOf[subschema #2]/destination_config/oneOf[#/components/schemas/DestinationGoogleSheetsConfig]/access_token` list-of-types was widened by adding types `null` to media type `application/x-ndjson`
- **2026-04-21** `c19b0d0a0631` — 1 warning, 2 info
  - removed the request property `oneOf[#/components/schemas/ControlMessage]/control/oneOf[subschema #1]/source_config/max_concurrent_streams`
  - the request property `oneOf[#/components/schemas/StreamStatusMessage]/stream_status/oneOf[subschema #1]/time_range/gte` became optional
  - the request property `oneOf[#/components/schemas/StreamStatusMessage]/stream_status/oneOf[subschema #1]/time_range/lt` became optional
- **2026-04-20** `98cef0c30f36` — 1 breaking
  - the `header` request parameter `x-pipeline` became required

[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/399c9fa011ec/schema)