From 6652edf7a7af175366daf1ec37763443ca379a67 Mon Sep 17 00:00:00 2001
From: Matt Aitken <matt@mattaitken.com>
Date: Thu, 15 Aug 2024 19:34:22 +0100
Subject: [PATCH] Disable upserting task queues when triggering a task

---
 .../app/v3/services/triggerTask.server.ts     | 76 +++++++++----------
 1 file changed, 38 insertions(+), 38 deletions(-)

diff --git a/apps/webapp/app/v3/services/triggerTask.server.ts b/apps/webapp/app/v3/services/triggerTask.server.ts
index b434f3471..c3fb3e155 100644
--- a/apps/webapp/app/v3/services/triggerTask.server.ts
+++ b/apps/webapp/app/v3/services/triggerTask.server.ts
@@ -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) {