From 8d34c63c2dd04d9f7afdea5f65edb0251690981b Mon Sep 17 00:00:00 2001
From: Eric Allam <eallam@icloud.com>
Date: Wed, 8 May 2024 10:19:06 +0100
Subject: [PATCH] Fix issue when concurrency limit is set to 0 on a queue

---
 apps/webapp/app/v3/services/createBackgroundWorker.server.ts | 2 +-
 references/v3-catalog/src/trigger/concurrency.ts             | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/webapp/app/v3/services/createBackgroundWorker.server.ts b/apps/webapp/app/v3/services/createBackgroundWorker.server.ts
index 4137d7a16c..2deb2c5373 100644
--- a/apps/webapp/app/v3/services/createBackgroundWorker.server.ts
+++ b/apps/webapp/app/v3/services/createBackgroundWorker.server.ts
@@ -172,7 +172,7 @@ export async function createBackgroundTasks(
         },
       });
 
-      if (taskQueue.concurrencyLimit) {
+      if (typeof taskQueue.concurrencyLimit === "number") {
         await marqs?.updateQueueConcurrencyLimits(
           environment,
           taskQueue.name,
diff --git a/references/v3-catalog/src/trigger/concurrency.ts b/references/v3-catalog/src/trigger/concurrency.ts
index 32ef2f4e82..d468029299 100644
--- a/references/v3-catalog/src/trigger/concurrency.ts
+++ b/references/v3-catalog/src/trigger/concurrency.ts
@@ -3,7 +3,7 @@ import { logger, task, wait } from "@trigger.dev/sdk/v3";
 export const oneAtATime = task({
   id: "on-at-a-time",
   queue: {
-    concurrencyLimit: 2,
+    concurrencyLimit: 1,
   },
   run: async (payload: { message: string }) => {
     logger.info("One at a time task payload", { payload });