fix(sdk): concurrency validation helpers live outside the task runtime module

triggerConcurrencyBody and validateConcurrencyLimitName move to a
dependency-free module so the chat-server route-handler entrypoint stays
lean instead of pulling the task runtime's import graph into customer
bundles.

Author: matt-aitken

packages/trigger-sdk/src/v3/ai.ts

@@ -118,7 +118,8 @@ import {
   sessions,
   type SessionSubscribeOptions,
 } from "./sessions.js";
-import { createTask, triggerConcurrencyBody } from "./shared.js";
+import { createTask } from "./shared.js";
+import { triggerConcurrencyBody } from "./concurrency-shared.js";
 import { markChatAgentRunForStreamsWarning } from "./streams.js";
 import { tracer } from "./tracer.js";
 

packages/trigger-sdk/src/v3/chat-server.ts

@@ -72,7 +72,7 @@ import {
 import type { FinishReason, ModelMessage, Tool, UIMessage, UIMessageChunk } from "ai";
 import type { ChatInputChunk, ChatTaskWirePayload } from "./ai-shared.js";
 import { chatRunTags } from "./ai-shared.js";
-import { triggerConcurrencyBody } from "./shared.js";
+import { triggerConcurrencyBody } from "./concurrency-shared.js";
 
 // `StreamTextResult` is defined locally rather than imported from `ai`: its
 // generic arity diverged (v6 `StreamTextResult<TOOLS, OUTPUT>`, v7

packages/trigger-sdk/src/v3/concurrency-shared.ts

@@ -0,0 +1,36 @@
+/**
+ * Concurrency helpers with no runtime dependencies, importable from the lean
+ * browser and route-handler entrypoints (chat-client, chat-server) without
+ * pulling the task runtime's module graph into those bundles.
+ */
+
+/**
+ * Trigger-time named limits: strings only, like `queue`. They replace the task's
+ * declared named limits for this run; the server resolves names to the run's gates.
+ */
+export function triggerConcurrencyBody(concurrency: string | string[] | undefined): {
+  concurrency?: string[];
+} {
+  if (!concurrency) {
+    return {};
+  }
+  const limits = Array.isArray(concurrency) ? concurrency : [concurrency];
+  if (limits.length > 2) {
+    throw new Error("The concurrency option accepts at most two named limits.");
+  }
+  if (limits.some((name) => typeof name !== "string" || name.length === 0)) {
+    throw new Error("The concurrency option takes limit names: non-empty strings.");
+  }
+  for (const name of limits) {
+    validateConcurrencyLimitName(name);
+  }
+  return { concurrency: limits };
+}
+
+export function validateConcurrencyLimitName(name: string): void {
+  if (!/^[a-zA-Z0-9_-]{1,122}$/.test(name)) {
+    throw new Error(
+      `Concurrency limit "${name}": names are 1-122 characters using only letters, numbers, underscores and hyphens.`
+    );
+  }
+}

packages/trigger-sdk/src/v3/shared.ts

@@ -95,6 +95,7 @@ import {
   type ConcurrencyLimit,
 } from "@trigger.dev/core/v3";
 import { tracer } from "./tracer.js";
+import { triggerConcurrencyBody, validateConcurrencyLimitName } from "./concurrency-shared.js";
 
 export type {
   AnyRunHandle,
@@ -213,29 +214,6 @@ function triggerQueueBody(
   return { queue: name ? { name } : undefined };
 }
 
-/**
- * Trigger-time named limits: strings only, like `queue`. They replace the task's
- * declared named limits for this run; the server resolves names to the run's gates.
- */
-export function triggerConcurrencyBody(concurrency: string | string[] | undefined): {
-  concurrency?: string[];
-} {
-  if (!concurrency) {
-    return {};
-  }
-  const limits = Array.isArray(concurrency) ? concurrency : [concurrency];
-  if (limits.length > 2) {
-    throw new Error("The concurrency option accepts at most two named limits.");
-  }
-  if (limits.some((name) => typeof name !== "string" || name.length === 0)) {
-    throw new Error("The concurrency option takes limit names: non-empty strings.");
-  }
-  for (const name of limits) {
-    validateConcurrencyLimitName(name);
-  }
-  return { concurrency: limits };
-}
-
 export function queue(options: QueueOptions): Queue {
   resourceCatalog.registerQueueMetadata(options);
 
@@ -261,14 +239,6 @@ export function queue(options: QueueOptions): Queue {
  * });
  * ```
  */
-function validateConcurrencyLimitName(name: string): void {
-  if (!/^[a-zA-Z0-9_-]{1,122}$/.test(name)) {
-    throw new Error(
-      `Concurrency limit "${name}": names are 1-122 characters using only letters, numbers, underscores and hyphens.`
-    );
-  }
-}
-
 export function concurrencyLimit(options: ConcurrencyLimitOptions): ConcurrencyLimit {
   validateConcurrencyLimitName(options.name);