See Stacksync in action with a solution architect. Book a demo ↗
Queues

Queues

Flush a queue

POST
/v1/workspaces/{workspace_id}/queues/{workflows_app_queue_id}/flush

Send the next record_count waiting records to the queue's consumer workflow now, whatever its flush rules. A queue without a consumer workflow is refused with 409: nothing could receive the records. With validate_only, the same checks run and 204 answers, nothing is requested.

Authorization

Authorizationstringheaderrequired

Bearer <key>, where <key> is a workspace API key or a user API key. See Authentication.

Path Parameters

workspace_id*integer

The workspace. List the ones your key can reach with GET /v1/workspaces.

workflows_app_queue_id*string

The queue.

Formatuuid

Query Parameters

region*Regions

Region of the resource: besg (Europe) or usnv (United States), as GET /v1/regions lists them

Value in"besg""usnv"

Request Body

application/json
  1. body
record_count*Record Count

Waiting records to send to the consumer now

Range1 <= value <= 10000
validate_only?Validate Only

Run every check of the write and answer 204 without writing: a refused write answers the error the write would

Defaultfalse

Response Body

OK

application/json
  1. response
queue_id*Queue Id
queue_name*Queue Name
queue_resource_id*Queue Resource Id
status*QueueStatus
Value in"running""paused"
consumer_workflow_id*|

The workflow that receives the flushed records, if any

flush_batch_size*Flush Batch Size

Records sent to the consumer workflow per flush

flush_record_max_age*|

Seconds a record may wait before the queue flushes

flush_rate_limit_max_flush_count*|

Maximum flushes per rate limit window

flush_rate_limit_time_window*|

The rate limit window, in seconds

flush_strategy*AppQueueFlushStrategy

fifo sends the oldest records first, lifo the newest

Value in"fifo""lifo"
parent_folder_id*string|null
created_time*Created Time
Formatdate-time
last_modified_time*Last Modified Time
Formatdate-time
region*Regions
Value in"besg""usnv"
flush_requested_record_count*Flush Requested Record Count
Flush a queue
curl -X POST 'https://api.stacksync.com/v1/workspaces/0/queues/497f6eca-6276-4993-bfeb-53cbbbba6f08/flush?region=besg' \  -H 'Content-Type: application/json' \  -d '{  "record_count": 1}'
{  "queue_id": "<queue_id>",  "queue_name": "<queue_name>",  "queue_resource_id": "<queue_resource_id>",  "status": "running",  "consumer_workflow_id": "<consumer_workflow_id>",  "flush_batch_size": 0,  "flush_record_max_age": 0,  "flush_rate_limit_max_flush_count": 0,  "flush_rate_limit_time_window": 0,  "flush_strategy": "fifo",  "parent_folder_id": "<parent_folder_id>",  "created_time": "2027-01-15T09:00:00Z",  "last_modified_time": "2027-01-15T09:00:00Z",  "region": "besg",  "flush_requested_record_count": 0}