We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a788c9f commit b06c42dCopy full SHA for b06c42d
1 file changed
apps/webapp/app/runEngine/concerns/queues.server.ts
@@ -186,6 +186,12 @@ export class DefaultQueueManager implements QueueManager {
186
187
const defaultQueueName = `task/${taskId}`;
188
189
+ // When caller provides both a queue override and a per-trigger TTL,
190
+ // we don't need any DB queries - the per-trigger TTL takes precedence
191
+ if (overriddenQueueName && body.options?.ttl !== undefined) {
192
+ return { queueName: overriddenQueueName, taskTtl: undefined };
193
+ }
194
+
195
// Find the current worker for the environment
196
const worker = await findCurrentWorkerFromEnvironment(environment, this.prisma);
197
0 commit comments