---
title: "POST /flows/{flowId}/write/enqueue"
method: POST
path: "/flows/{flowId}/write/enqueue"
tags: ["flow"]
---

# POST /flows/{flowId}/write/enqueue

`POST /flows/{flowId}/write/enqueue`

## Request

- Base URL: `https://headless.dataddo.com/customer-api/v1`
- URL: `https://headless.dataddo.com/customer-api/v1/flows/{flowId}/write/enqueue`
- Auth: none declared

Enqueues a manual write run for the given flow

## Path parameters

- `flowId` string, required

## Request body

- PostEnqueueFlowInput
  - `skip_validation_rules` boolean
  - `date_range_expression` string, nullable: A "1d1" formatted value
  - `source_revisions` object, nullable: Map of sourceId to revision number. Sources not listed use the latest revision.

## Response `202`

Enqueues the write action

- ActionEnqueuedResource
  - `execution_id` string
  - `action_id` string
  - `action_type` 'extraction' | 'write' | 'webhook' | 'data_fetch' | 'unknown'
  - `connector` string
  - `started_at` integer: UNIX timestamp in seconds.
  - `executionId` string
  - `actionId` string
  - `actionType` 'extraction' | 'write' | 'webhook' | 'data_fetch' | 'unknown'
  - `startedAt` integer: UNIX timestamp in seconds.

---

[API](https://skmtc.dev/dataddo/apis/dataddo-headless-beta-api.md) · [All operations](https://skmtc.dev/dataddo/apis/dataddo-headless-beta-api/llms.txt) · [OpenAPI document](https://skmtc.dev/dataddo/apis/dataddo-headless-beta-api/revisions/dcfa2345bd10?raw)