diff --git a/apps/webapp/app/v3/services/createBackgroundWorker.server.ts b/apps/webapp/app/v3/services/createBackgroundWorker.server.ts index 79a5e28784..9045075e13 100644 --- a/apps/webapp/app/v3/services/createBackgroundWorker.server.ts +++ b/apps/webapp/app/v3/services/createBackgroundWorker.server.ts @@ -173,7 +173,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 });