queues
Installation
SKILL.md
What it is
A queue holds records until its flush rules send them to one consumer workflow as a batch.
- Producers add records: workflows with a queue insert step, and syncs with a sync event
trigger of type
queue(one record per changed record). - The consumer is the workflow whose trigger is the queue. Each flush starts one run of it with the whole batch as an array.
- A queue's
statusisrunningorpaused.
| Flush rule | Field | Default | Range |
|---|---|---|---|
| Batch size: records per flush | flush_batch_size |
1,000 | 1 to 10,000 |
| Maximum age: seconds a record may wait before a flush, even when the batch is not full | flush_record_max_age |
60 | 1 to 86,400 |
| Flushes allowed per rate limit window | flush_rate_limit_max_flush_count |
10 | from 1 |
| Rate limit window, in seconds | flush_rate_limit_time_window |
1 | from 1 |
Order: fifo sends the oldest records first, lifo the newest |
flush_strategy |
fifo |