Skip to content

Commit 1772166

Browse files
committed
docs: imports for the standalone queue examples
1 parent 74e5c15 commit 1772166

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

docs/queue-concurrency.mdx

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -174,6 +174,8 @@ export async function POST(request: Request) {
174174
To bound the whole queue, set `combinedConcurrencyLimit`. Each key still gets at most `concurrencyLimit`, and the queue as a whole never exceeds the combined limit across all keys:
175175

176176
```ts /trigger/per-user.ts
177+
import { queue } from "@trigger.dev/sdk";
178+
177179
export const perUserQueue = queue({
178180
name: "per-user-queue",
179181
//each user runs at most 1 at a time...
@@ -208,6 +210,8 @@ await processWebhook.trigger(payload, {
208210
A gate without a `concurrencyKey` uses the run's own key. Declare a shared queue and gate every relevant task on it, and each tenant gets one cap spanning all of those tasks:
209211

210212
```ts /trigger/webhooks.ts
213+
import { queue, task } from "@trigger.dev/sdk";
214+
211215
//each tenant runs at most 10 at once across every task that gates on this queue
212216
export const tenantQueue = queue({ name: "tenant", concurrencyLimit: 10 });
213217

@@ -232,6 +236,8 @@ Because the trigger passes a `concurrencyKey`, the home queue splits per key as
232236
To cap something global, like total traffic to an external API, across many tasks and all tenants: declare a queue with only a `combinedConcurrencyLimit` and gate on it. Tenant keys still split the gate into per-key pools, but with no per-key limit the combined cap is the only constraint:
233237

234238
```ts /trigger/sync.ts
239+
import { queue, task } from "@trigger.dev/sdk";
240+
235241
//at most 10 concurrent provider calls across every task and every tenant
236242
export const providerApiQueue = queue({
237243
name: "provider-api",
@@ -263,6 +269,8 @@ await syncToProvider.trigger(payload, { concurrencyKey: tenantId });
263269
Give a gate a literal `concurrencyKey` to pin every run into a single first-come-first-served pool, regardless of each run's own key:
264270

265271
```ts /trigger/print.ts
272+
import { queue, task } from "@trigger.dev/sdk";
273+
266274
export const printerQueue = queue({ name: "printer", concurrencyLimit: 1 });
267275

268276
export const printLabel = task({

0 commit comments

Comments
 (0)