github-featured/triggerdotdev--trigger.dev
2
0
Fork 0
Code Issues Pull Requests Deployments Models Agent Notes Packages Projects Releases Wiki Activity

Disable upserting task queues when triggering a task

Browse Source
This commit is contained in:
Matt Aitken
2024-08-15 19:34:22 +01:00
parent 369bc38560
commit 6652edf7a7
1 changed files with 38 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/webapp/app/v3/services/triggerTask.server.ts
+38 -38
View File
@@ -311,46 +311,46 @@ export class TriggerTaskService extends BaseService {
? Math.max(0, body.options.queue.concurrencyLimit)
: undefined;
let taskQueue = await tx.taskQueue.findFirst({
where: {
runtimeEnvironmentId: environment.id,
name: queueName,
},
});
// let taskQueue = await tx.taskQueue.findFirst({
// where: {
// runtimeEnvironmentId: environment.id,
// name: queueName,
// },
// });
if (taskQueue) {
taskQueue = await tx.taskQueue.update({
where: {
id: taskQueue.id,
},
data: {
concurrencyLimit,
rateLimit: body.options.queue.rateLimit,
},
});
} else {
taskQueue = await tx.taskQueue.create({
data: {
friendlyId: generateFriendlyId("queue"),
name: queueName,
concurrencyLimit,
runtimeEnvironmentId: environment.id,
projectId: environment.projectId,
rateLimit: body.options.queue.rateLimit,
type: "NAMED",
},
});
}
// if (taskQueue) {
// taskQueue = await tx.taskQueue.update({
// where: {
// id: taskQueue.id,
// },
// data: {
// concurrencyLimit,
// rateLimit: body.options.queue.rateLimit,
// },
// });
// } else {
// taskQueue = await tx.taskQueue.create({
// data: {
// friendlyId: generateFriendlyId("queue"),
// name: queueName,
// concurrencyLimit,
// runtimeEnvironmentId: environment.id,
// projectId: environment.projectId,
// rateLimit: body.options.queue.rateLimit,
// type: "NAMED",
// },
// });
// }
if (typeof taskQueue.concurrencyLimit === "number") {
await marqs?.updateQueueConcurrencyLimits(
environment,
taskQueue.name,
taskQueue.concurrencyLimit
);
} else {
await marqs?.removeQueueConcurrencyLimits(environment, taskQueue.name);
}
// if (typeof taskQueue.concurrencyLimit === "number") {
// await marqs?.updateQueueConcurrencyLimits(
// environment,
// taskQueue.name,
// taskQueue.concurrencyLimit
// );
// } else {
// await marqs?.removeQueueConcurrencyLimits(environment, taskQueue.name);
// }
}
if (taskRun.delayUntil) {