Skip to content

Commit 5bae166

Browse files
committed
Allow task queue to have releaseConcurrencyOnWaitpoint (required to fix custom queues)
1 parent dc8f047 commit 5bae166

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

packages/core/src/v3/types/tasks.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -206,6 +206,7 @@ type CommonTaskOptions<
206206
queue?: {
207207
name?: string;
208208
concurrencyLimit?: number;
209+
releaseConcurrencyOnWaitpoint?: boolean;
209210
};
210211
/** Configure the spec of the [machine](https://trigger.dev/docs/machines) you want your task to run on.
211212
*

packages/trigger-sdk/src/v3/shared.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,6 @@ export { SubtaskUnwrapError, TaskRunPromise };
119119
export type Context = TaskRunContext;
120120

121121
export function queue(options: QueueOptions): Queue {
122-
// TODO register queue here
123122
resourceCatalog.registerQueueMetadata(options);
124123

125124
// @ts-expect-error
@@ -215,6 +214,7 @@ export function createTask<
215214
resourceCatalog.registerQueueMetadata({
216215
name: queue.name,
217216
concurrencyLimit: queue.concurrencyLimit,
217+
releaseConcurrencyOnWaitpoint: queue.releaseConcurrencyOnWaitpoint,
218218
});
219219
}
220220

@@ -346,6 +346,7 @@ export function createSchemaTask<
346346
resourceCatalog.registerQueueMetadata({
347347
name: queue.name,
348348
concurrencyLimit: queue.concurrencyLimit,
349+
releaseConcurrencyOnWaitpoint: queue.releaseConcurrencyOnWaitpoint,
349350
});
350351
}
351352

0 commit comments

Comments
 (0)