Fix pnpm lock file

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

.changeset/green-bags-wink.md

@@ -0,0 +1,5 @@
+---
+"@trigger.dev/react": patch
+---
+
+Fix for shared queryKey between useRunDetails and useRunStatuses

.changeset/pre.json

@@ -48,6 +48,7 @@
     "chilled-hornets-move",
     "clean-pianos-listen",
     "cool-glasses-bake",
+    "green-bags-wink",
     "khaki-apricots-design",
     "lemon-jobs-repair",
     "light-bulldogs-press",

apps/coordinator/src/index.ts

@@ -18,6 +18,8 @@ collectDefaultMetrics();
 
 const HTTP_SERVER_PORT = Number(process.env.HTTP_SERVER_PORT || 8020);
 const NODE_NAME = process.env.NODE_NAME || "coordinator";
+const DEFAULT_RETRY_DELAY_THRESHOLD_IN_MS = 30_000;
+
 const REGISTRY_HOST = process.env.REGISTRY_HOST || "localhost:5000";
 const CHECKPOINT_PATH = process.env.CHECKPOINT_PATH || "/checkpoints";
 const REGISTRY_TLS_VERIFY = process.env.REGISTRY_TLS_VERIFY === "false" ? "false" : "true";
@@ -334,12 +336,19 @@ class TaskCoordinator {
     { resolve: (value: void) => void; reject: (err?: any) => void }
   >();
 
+  #delayThresholdInMs: number;
+
   constructor(
     private port: number,
     private host = "0.0.0.0"
   ) {
     this.#httpServer = this.#createHttpServer();
     this.#checkpointer.initialize();
+    this.#delayThresholdInMs = this.#getDelayThreshold();
+
+    if (process.env.DELAY_THRESHOLD_IN_MS) {
+      this.#delayThresholdInMs = this.#getDelayThreshold();
+    }
 
     const io = new Server(this.#httpServer);
     this.#prodWorkerNamespace = this.#createProdWorkerNamespace(io);
@@ -356,6 +365,27 @@ class TaskCoordinator {
     register.registerMetric(connectedTasksTotal);
   }
 
+  #getDelayThreshold() {
+    if (!process.env.RETRY_DELAY_THRESHOLD_IN_MS) {
+      return DEFAULT_RETRY_DELAY_THRESHOLD_IN_MS;
+    }
+
+    const threshold = parseInt(process.env.RETRY_DELAY_THRESHOLD_IN_MS);
+
+    if (isNaN(threshold)) {
+      logger.log(
+        "RETRY_DELAY_THRESHOLD_IN_MS parses as NaN, must supply integer. Will use default instead.",
+        {
+          RETRY_DELAY_THRESHOLD_IN_MS: process.env.RETRY_DELAY_THRESHOLD_IN_MS,
+          DEFAULT_DELAY_THRESHOLD_IN_MS: DEFAULT_RETRY_DELAY_THRESHOLD_IN_MS,
+        }
+      );
+      return DEFAULT_RETRY_DELAY_THRESHOLD_IN_MS;
+    }
+
+    return threshold;
+  }
+
   #createPlatformSocket() {
     if (!PLATFORM_ENABLED) {
       console.log("INFO: platform connection disabled");
@@ -629,7 +659,7 @@ class TaskCoordinator {
             return;
           }
 
-          if (completion.retry.delay < 10_000) {
+          if (completion.retry.delay < this.#delayThresholdInMs) {
             completeWithoutCheckpoint(false);
             return;
           }

apps/webapp/app/env.server.ts

@@ -19,6 +19,7 @@ const EnvironmentSchema = z.object({
   LOGIN_ORIGIN: z.string().default("http://localhost:3030"),
   APP_ORIGIN: z.string().default("http://localhost:3030"),
   APP_ENV: z.string().default(process.env.NODE_ENV),
+  SERVICE_NAME: z.string().default("trigger.dev webapp"),
   SECRET_STORE: SecretStoreOptionsSchema.default("DATABASE"),
   POSTHOG_PROJECT_KEY: z.string().optional(),
   TELEMETRY_TRIGGER_API_KEY: z.string().optional(),
@@ -87,8 +88,6 @@ const EnvironmentSchema = z.object({
 
   //v3
   V3_ENABLED: z.string().default("false"),
-  IMAGE_REGISTRY: z.string().default("docker.io"),
-  IMAGE_REPO: z.string().default("task"),
   PROVIDER_SECRET: z.string().default("provider-secret"),
   COORDINATOR_SECRET: z.string().default("coordinator-secret"),
   DEPOT_TOKEN: z.string().optional(),
@@ -103,6 +102,9 @@ const EnvironmentSchema = z.object({
   EVENTS_BATCH_SIZE: z.coerce.number().int().default(100),
   EVENTS_BATCH_INTERVAL: z.coerce.number().int().default(1000),
   EVENTS_DEFAULT_LOG_RETENTION: z.coerce.number().int().default(7),
+  SHARED_QUEUE_CONSUMER_POOL_SIZE: z.coerce.number().int().default(10),
+  SHARED_QUEUE_CONSUMER_INTERVAL_MS: z.coerce.number().int().default(100),
+  SHARED_QUEUE_CONSUMER_NEXT_TICK_INTERVAL_MS: z.coerce.number().int().default(100),
 
   // Development OTEL environment variables
   DEV_OTEL_EXPORTER_OTLP_ENDPOINT: z.string().optional(),

apps/webapp/app/v3/handleSocketIo.server.ts

@@ -168,6 +168,7 @@ function createSharedQueueConsumerNamespace(io: Server) {
         namespace: sharedQueue.namespace,
         socket,
         logger,
+        poolSize: env.SHARED_QUEUE_CONSUMER_POOL_SIZE,
       });
 
       sharedSocketConnection.onClose.attach((closeEvent) => {

apps/webapp/app/v3/marqs/index.server.ts

@@ -1,4 +1,9 @@
-import { Span, SpanKind, SpanOptions, trace } from "@opentelemetry/api";
+import { Span, SpanKind, SpanOptions, context, propagation, trace } from "@opentelemetry/api";
+import {
+  SEMATTRS_MESSAGE_ID,
+  SEMATTRS_MESSAGING_OPERATION,
+  SEMATTRS_MESSAGING_SYSTEM,
+} from "@opentelemetry/semantic-conventions";
 import { flattenAttributes } from "@trigger.dev/core/v3";
 import Redis, { type Callback, type RedisOptions, type Result } from "ioredis";
 import { env } from "~/env.server";
@@ -98,6 +103,8 @@ export class MarQS {
 
         const parentQueue = this.keys.envSharedQueueKey(env);
 
+        propagation.inject(context.active(), messageData);
+
         const messagePayload: MessagePayload = {
           version: "1",
           data: messageData,
@@ -117,7 +124,15 @@ export class MarQS {
 
         await this.#callEnqueueMessage(messagePayload);
       },
-      { kind: SpanKind.PRODUCER, attributes: { ...attributesFromAuthenticatedEnv(env) } }
+      {
+        kind: SpanKind.PRODUCER,
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "publish",
+          [SEMATTRS_MESSAGE_ID]: messageId,
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+          ...attributesFromAuthenticatedEnv(env),
+        },
+      }
     );
   }
 
@@ -160,6 +175,7 @@ export class MarQS {
 
         if (message) {
           span.setAttributes({
+            [SEMATTRS_MESSAGE_ID]: message.messageId,
             [SemanticAttributes.QUEUE]: message.queue,
             [SemanticAttributes.MESSAGE_ID]: message.messageId,
             [SemanticAttributes.CONCURRENCY_KEY]: message.concurrencyKey,
@@ -171,7 +187,14 @@ export class MarQS {
 
         return message;
       },
-      { kind: SpanKind.CONSUMER, attributes: { ...attributesFromAuthenticatedEnv(env) } }
+      {
+        kind: SpanKind.CONSUMER,
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "receive",
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+          ...attributesFromAuthenticatedEnv(env),
+        },
+      }
     );
   }
 
@@ -218,6 +241,7 @@ export class MarQS {
 
         if (message) {
           span.setAttributes({
+            [SEMATTRS_MESSAGE_ID]: message.messageId,
             [SemanticAttributes.QUEUE]: message.queue,
             [SemanticAttributes.MESSAGE_ID]: message.messageId,
             [SemanticAttributes.CONCURRENCY_KEY]: message.concurrencyKey,
@@ -229,7 +253,13 @@ export class MarQS {
 
         return message;
       },
-      { kind: SpanKind.CONSUMER }
+      {
+        kind: SpanKind.CONSUMER,
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "receive",
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+        },
+      }
     );
   }
 
@@ -259,7 +289,14 @@ export class MarQS {
           messageId,
         });
       },
-      { kind: SpanKind.CONSUMER }
+      {
+        kind: SpanKind.CONSUMER,
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "ack",
+          [SEMATTRS_MESSAGE_ID]: messageId,
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+        },
+      }
     );
   }
 
@@ -305,7 +342,14 @@ export class MarQS {
 
         await this.#callEnqueueMessage(newMessage);
       },
-      { kind: SpanKind.CONSUMER }
+      {
+        kind: SpanKind.CONSUMER,
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "replace",
+          [SEMATTRS_MESSAGE_ID]: messageId,
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+        },
+      }
     );
   }
 
@@ -370,7 +414,14 @@ export class MarQS {
           messageScore: retryAt,
         });
       },
-      { kind: SpanKind.CONSUMER }
+      {
+        kind: SpanKind.CONSUMER,
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "nack",
+          [SEMATTRS_MESSAGE_ID]: messageId,
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+        },
+      }
     );
   }
 
@@ -411,7 +462,14 @@ export class MarQS {
 
         return message.data;
       },
-      { attributes: { [SemanticAttributes.MESSAGE_ID]: messageId } }
+      {
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "receive",
+          [SEMATTRS_MESSAGE_ID]: messageId,
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+          [SemanticAttributes.MESSAGE_ID]: messageId,
+        },
+      }
     );
   }
 
@@ -455,7 +513,14 @@ export class MarQS {
 
         return choice;
       },
-      { kind: SpanKind.CONSUMER, attributes: { [SemanticAttributes.PARENT_QUEUE]: parentQueue } }
+      {
+        kind: SpanKind.CONSUMER,
+        attributes: {
+          [SEMATTRS_MESSAGING_OPERATION]: "receive",
+          [SEMATTRS_MESSAGING_SYSTEM]: "marqs",
+          [SemanticAttributes.PARENT_QUEUE]: parentQueue,
+        },
+      }
     );
   }
 

apps/webapp/app/v3/marqs/sharedQueueConsumer.server.ts

@@ -1,4 +1,12 @@
-import { Context, ROOT_CONTEXT, Span, SpanKind, context, trace } from "@opentelemetry/api";
+import {
+  Context,
+  ROOT_CONTEXT,
+  Span,
+  SpanKind,
+  context,
+  propagation,
+  trace,
+} from "@opentelemetry/api";
 import {
   Machine,
   ProdTaskRunExecution,
@@ -31,19 +39,24 @@ import { findCurrentWorkerDeployment } from "../models/workerDeployment.server";
 
 const tracer = trace.getTracer("sharedQueueConsumer");
 
+const WithTraceContext = z.object({
+  traceparent: z.string().optional(),
+  tracestate: z.string().optional(),
+});
+
 const MessageBody = z.discriminatedUnion("type", [
-  z.object({
+  WithTraceContext.extend({
     type: z.literal("EXECUTE"),
     taskIdentifier: z.string(),
     checkpointEventId: z.string().optional(),
   }),
-  z.object({
+  WithTraceContext.extend({
     type: z.literal("RESUME"),
     completedAttemptIds: z.string().array(),
     resumableAttemptId: z.string(),
     checkpointEventId: z.string().optional(),
   }),
-  z.object({
+  WithTraceContext.extend({
     type: z.literal("RESUME_AFTER_DURATION"),
     resumableAttemptId: z.string(),
     checkpointEventId: z.string(),
@@ -57,6 +70,7 @@ export type SharedQueueConsumerOptions = {
   traceTimeoutSeconds?: number;
   nextTickInterval?: number;
   interval?: number;
+  parentContext?: Context;
 };
 
 export class SharedQueueConsumer {
@@ -83,6 +97,7 @@ export class SharedQueueConsumer {
       traceTimeoutSeconds: options.traceTimeoutSeconds ?? 60, // 60 seconds
       nextTickInterval: options.nextTickInterval ?? 1000, // 1 second
       interval: options.interval ?? 100, // 100ms
+      parentContext: options.parentContext ?? ROOT_CONTEXT,
     };
   }
 
@@ -187,8 +202,17 @@ export class SharedQueueConsumer {
     this.#doWork().finally(() => {});
   }
 
+  #endCurrentSpan() {
+    if (this._currentSpan) {
+      this._currentSpan.setAttribute("tasks.period.failures", this._taskFailures);
+      this._currentSpan.setAttribute("tasks.period.successes", this._taskSuccesses);
+      this._currentSpan.end();
+    }
+  }
+
   async #doWork() {
     if (!this._enabled) {
+      this.#endCurrentSpan();
       return;
     }
 
@@ -199,12 +223,9 @@ export class SharedQueueConsumer {
       this._currentSpanContext === undefined ||
       this._endSpanInNextIteration
     ) {
-      if (this._currentSpan) {
-        this._currentSpan.setAttribute("tasks.period.failures", this._taskFailures);
-        this._currentSpan.setAttribute("tasks.period.successes", this._taskSuccesses);
+      this.#endCurrentSpan();
 
-        this._currentSpan.end();
-      }
+      const parentContext = this._options.parentContext ?? ROOT_CONTEXT;
 
       // Create a new trace
       this._currentSpan = tracer.startSpan(
@@ -212,11 +233,11 @@ export class SharedQueueConsumer {
         {
           kind: SpanKind.CONSUMER,
         },
-        ROOT_CONTEXT
+        parentContext
       );
 
       // Get the span trace context
-      this._currentSpanContext = trace.setSpan(ROOT_CONTEXT, this._currentSpan);
+      this._currentSpanContext = trace.setSpan(parentContext, this._currentSpan);
 
       this._perTraceCountdown = this._options.maximumItemsPerTrace;
       this._lastNewTrace = new Date();

apps/webapp/app/v3/sharedSocketConnection.ts

@@ -10,7 +10,56 @@ import { Evt } from "evt";
 import { randomUUID } from "node:crypto";
 import { logger } from "~/services/logger.server";
 import { SharedQueueConsumer } from "./marqs/sharedQueueConsumer.server";
-import { DisconnectReason, Namespace, Socket } from "socket.io";
+import type { DisconnectReason, Namespace, Socket } from "socket.io";
+import { ROOT_CONTEXT, Span, SpanKind, trace } from "@opentelemetry/api";
+import { env } from "~/env.server";
+
+const tracer = trace.getTracer("sharedQueueConsumerPool");
+
+interface SharedQueueConsumerPoolOptions {
+  sender: ZodMessageSender<typeof serverWebsocketMessages>;
+  poolSize: number;
+}
+
+class SharedQueueConsumerPool {
+  #consumers: SharedQueueConsumer[];
+  #span: Span;
+
+  constructor(opts: SharedQueueConsumerPoolOptions) {
+    this.#span = tracer.startSpan(
+      "SharedQueueConsumerPool()",
+      {
+        kind: SpanKind.CONSUMER,
+        attributes: {
+          "pool.size": opts.poolSize,
+        },
+      },
+      ROOT_CONTEXT
+    );
+
+    const spanContext = trace.setSpan(ROOT_CONTEXT, this.#span);
+
+    this.#consumers = Array(opts.poolSize)
+      .fill(null)
+      .map(
+        () =>
+          new SharedQueueConsumer(opts.sender, {
+            interval: env.SHARED_QUEUE_CONSUMER_INTERVAL_MS,
+            nextTickInterval: env.SHARED_QUEUE_CONSUMER_NEXT_TICK_INTERVAL_MS,
+            parentContext: spanContext,
+          })
+      );
+  }
+
+  async start() {
+    await Promise.allSettled(this.#consumers.map((consumer) => consumer.start()));
+  }
+
+  async stop() {
+    await Promise.allSettled(this.#consumers.map((consumer) => consumer.stop()));
+    this.#span.end();
+  }
+}
 
 interface SharedSocketConnectionOptions {
   namespace: Namespace<
@@ -22,6 +71,7 @@ interface SharedSocketConnectionOptions {
     MessageCatalogToSocketIoEvents<typeof serverWebsocketMessages>
   >;
   logger?: StructuredLogger;
+  poolSize?: number;
 }
 
 export class SharedSocketConnection {
@@ -29,8 +79,9 @@ export class SharedSocketConnection {
   public onClose: Evt<DisconnectReason> = new Evt();
 
   private _sender: ZodMessageSender<typeof serverWebsocketMessages>;
-  private _sharedConsumer: SharedQueueConsumer;
+  private _sharedQueueConsumerPool: SharedQueueConsumerPool;
   private _messageHandler: ZodMessageHandler<typeof clientWebsocketMessages>;
+  private _defaultPoolSize = 10;
 
   constructor(opts: SharedSocketConnectionOptions) {
     this.id = randomUUID();
@@ -50,9 +101,13 @@ export class SharedSocketConnection {
       },
     });
 
-    this._sharedConsumer = new SharedQueueConsumer(this._sender, {
-      interval: 100,
-      nextTickInterval: 1000,
+    logger.log("Starting SharedQueueConsumer pool", {
+      poolSize: opts.poolSize ?? this._defaultPoolSize,
+    });
+
+    this._sharedQueueConsumerPool = new SharedQueueConsumerPool({
+      poolSize: opts.poolSize ?? this._defaultPoolSize,
+      sender: this._sender,
     });
 
     opts.socket.on("disconnect", this.#handleClose.bind(this));
@@ -62,7 +117,7 @@ export class SharedSocketConnection {
       schema: clientWebsocketMessages,
       messages: {
         READY_FOR_TASKS: async (payload) => {
-          this._sharedConsumer.start();
+          this._sharedQueueConsumerPool.start();
         },
         BACKGROUND_WORKER_DEPRECATED: async (payload) => {
           // await this._sharedConsumer.deprecateBackgroundWorker(payload.backgroundWorkerId);
@@ -89,7 +144,7 @@ export class SharedSocketConnection {
   }
 
   async #handleClose(ev: DisconnectReason) {
-    await this._sharedConsumer.stop();
+    await this._sharedQueueConsumerPool.stop();
 
     this.onClose.post(ev);
   }

apps/webapp/app/v3/tracer.server.ts

@@ -68,7 +68,7 @@ function getTracer() {
   const provider = new NodeTracerProvider({
     forceFlushTimeoutMillis: 500,
     resource: new Resource({
-      [SEMRESATTRS_SERVICE_NAME]: "trigger.dev",
+      [SEMRESATTRS_SERVICE_NAME]: env.SERVICE_NAME,
     }),
     sampler: new ParentBasedSampler({
       root: new CustomWebappSampler(new TraceIdRatioBasedSampler(samplingRate)), // 5% sampling

integrations/airtable/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/airtable
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/airtable/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/airtable",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev integration for airtable",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "airtable": "^0.12.1",
     "zod": "3.22.3"
   },

integrations/github/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/github
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/github/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/github",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "The official GitHub integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -30,8 +30,8 @@
     "@octokit/request-error": "^5.0.1",
     "@octokit/webhooks": "^12.0.10",
     "octokit": "^3.1.2",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "zod": "3.22.3"
   },
   "engines": {

integrations/linear/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/linear
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/linear/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/linear",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev integration for @linear/sdk",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@linear/sdk": "^8.0.0",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "zod": "3.22.3"
   },
   "engines": {

integrations/openai/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/slack
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/openai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/openai",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "The official OpenAI integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -42,8 +42,8 @@
   },
   "dependencies": {
     "openai": "^4.16.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4"
   },
   "engines": {
     "node": ">=18.0.0"

integrations/plain/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/plain
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/plain/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/plain",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "The official Plain.com integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "build:tsup": "tsup"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "@team-plain/typescript-sdk": "^2.7.0"
   },
   "engines": {

integrations/replicate/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/replicate
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/replicate/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/replicate",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev integration for replicate",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "replicate": "^0.18.1",
     "zod": "3.22.3"
   },

integrations/resend/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/resend
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/resend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/resend",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "The official Resend.com integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "build:tsup": "tsup"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "resend": "^2.1.0"
   },
   "engines": {

integrations/sendgrid/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/sendgrid
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/sendgrid/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sendgrid",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev integration for @sendgrid/mail",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@sendgrid/mail": "^7.7.0",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4"
   },
   "engines": {
     "node": ">=16.8.0"

integrations/shopify/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/shopify
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/shopify/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/shopify",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev integration for @shopify/shopify-api",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@shopify/shopify-api": "^8.0.2",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
     "zod": "3.22.3"
   },
   "engines": {

integrations/slack/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/slack
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/slack/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/slack",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "The official Slack integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,7 +25,7 @@
   },
   "dependencies": {
     "@slack/web-api": "^6.8.1",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "zod": "3.22.3"
   },
   "engines": {

integrations/stripe/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/stripe
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/stripe/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/stripe",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev integration for stripe",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "stripe": "^12.14.0",
     "zod": "3.22.3"
   },

integrations/supabase/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/supabase
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/supabase/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/supabase",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev integration for @supabase/supabase-js",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@supabase/supabase-js": "^2.26.0",
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "supabase-management-js": "^1.0.0",
     "zod": "3.22.3"
   },

integrations/typeform/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/typeform
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

integrations/typeform/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/typeform",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "The official Typeform integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/integration-kit": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "@typeform/api-client": "^1.8.0",
     "zod": "3.22.3"
   },

packages/astro/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/astro
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/astro/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@trigger.dev/astro",
   "description": "An Astro-native integration for Trigger.dev background jobs platform",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "files": [
@@ -20,7 +20,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4"
   },
   "devDependencies": {
     "astro": "^3.0.12",

packages/cli-v3/package.json

@@ -89,7 +89,7 @@
     "@opentelemetry/sdk-trace-base": "^1.22.0",
     "@opentelemetry/sdk-trace-node": "^1.22.0",
     "@opentelemetry/semantic-conventions": "^1.22.0",
-    "@trigger.dev/core": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/core": "workspace:^3.0.0-beta.4",
     "@types/degit": "^2.8.3",
     "chalk": "^5.2.0",
     "chokidar": "^3.5.3",

packages/cli/CHANGELOG.md

@@ -1,5 +1,12 @@
 # create-trigger
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/core@3.0.0-beta.4
+- @trigger.dev/yalt@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/cli",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "The Trigger.dev CLI",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/core-apps/CHANGELOG.md

@@ -1,5 +1,7 @@
 # @trigger.dev/core-apps
 
+## 3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ## 3.0.0-beta.2

packages/core-apps/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@trigger.dev/core-apps",
   "description": "Backend core code used across apps",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "private": true,
   "license": "MIT",
   "main": "./dist/index.js",

packages/core-backend/CHANGELOG.md

@@ -1,5 +1,7 @@
 # @trigger.dev/core-backend
 
+## 3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ## 3.0.0-beta.2

packages/core-backend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/core-backend",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Core code used across `@trigger.dev/sdk` and Trigger.dev server",
   "license": "MIT",
   "main": "./dist/index.js",

packages/core/CHANGELOG.md

@@ -1,5 +1,7 @@
 # internal-platform
 
+## 3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/core",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Core code used across the Trigger.dev SDK and platform",
   "license": "MIT",
   "main": "./dist/index.js",

packages/eslint-plugin/CHANGELOG.md

@@ -1,5 +1,7 @@
 # @trigger.dev/eslint-plugin
 
+## 3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ## 3.0.0-beta.2

packages/eslint-plugin/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/eslint-plugin",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "ESLint plugin with trigger.dev best practices",
   "keywords": [
     "eslint",

packages/express/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/express
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/express/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/express",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Official Express adapter for Trigger.dev",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -23,7 +23,7 @@
     "./package.json": "./package.json"
   },
   "devDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "@trigger.dev/tsconfig": "workspace:*",
     "@types/debug": "^4.1.7",
     "@types/express": "^4.17.13",
@@ -39,7 +39,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4"
   },
   "dependencies": {
     "debug": "^4.3.4",

packages/hono/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/hono
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/hono/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/hono",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "A Trigger.dev adapter for Hono.dev",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -32,7 +32,7 @@
   },
   "peerDependencies": {
     "hono": "3.x",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4"
   },
   "devDependencies": {
     "@trigger.dev/tsconfig": "workspace:*",

packages/integration-kit/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/integration-kit
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/core@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/integration-kit/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/integration-kit",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev Integration Kit has helpers to make creating integrations easier",
   "license": "MIT",
   "main": "./dist/index.js",

packages/nestjs/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/nestjs
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/nestjs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/nestjs",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Official NestJS adapter for Trigger.dev",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -23,7 +23,7 @@
     "./package.json": "./package.json"
   },
   "devDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "@trigger.dev/tsconfig": "workspace:*",
     "@types/debug": "^4.1.7",
     "@types/express": "^4.17.13",
@@ -41,7 +41,7 @@
   },
   "peerDependencies": {
     "@nestjs/common": ">=10.0.0",
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4"
   },
   "dependencies": {
     "@nestjs/common": "^10.2.4",

packages/nextjs/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/nextjs
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/nextjs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/nextjs",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev Next.js integration",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -41,7 +41,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "next": ">=12.0.0"
   },
   "dependencies": {

packages/otlp-importer/CHANGELOG.md

@@ -1,5 +1,7 @@
 # @trigger.dev/otlp-importer
 
+## 3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ## 3.0.0-beta.2

packages/otlp-importer/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/otlp-importer",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "OpenTelemetry OTLP Importer for Node.js written in TypeScript",
   "license": "MIT",
   "main": "./dist/index.js",

packages/react/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/react
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- 545f85b44: Fix for shared queryKey between useRunDetails and useRunStatuses
+  - @trigger.dev/core@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/react/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/react",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev React SDK",
   "license": "MIT",
   "types": "dist/index.d.ts",
@@ -27,7 +27,7 @@
   },
   "dependencies": {
     "@tanstack/react-query": "5.0.0-beta.2",
-    "@trigger.dev/core": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/core": "workspace:^3.0.0-beta.4",
     "debug": "^4.3.4",
     "zod": "3.22.3"
   },

packages/react/src/statuses.ts

@@ -47,7 +47,7 @@ export function useRunStatuses(
 
   const queryResult = useQuery(
     {
-      queryKey: [`triggerdotdev-run-${runId}`],
+      queryKey: [`triggerdotdev-run-statuses-${runId}`],
       queryFn: async () => {
         return await zodfetch(GetRunStatusesSchema, `${apiUrl}/api/v2/runs/${runId}/statuses`, {
           method: "GET",

packages/remix/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/remix
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/remix/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/remix",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev Remix integration",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -39,7 +39,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4",
     "@remix-run/server-runtime": ">1.19.0"
   },
   "dependencies": {

packages/sveltekit/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/sveltekit
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/sveltekit/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sveltekit",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "Trigger.dev svelteKit integration",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -39,7 +39,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^3.0.0-beta.3"
+    "@trigger.dev/sdk": "workspace:^3.0.0-beta.4"
   },
   "dependencies": {
     "debug": "^4.3.4"

packages/testing/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/testing
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/core@3.0.0-beta.4
+- @trigger.dev/sdk@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/testing/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@trigger.dev/testing",
   "description": "A collection of useful tools to write tests for Trigger.dev.",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "license": "MIT",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/trigger-sdk/CHANGELOG.md

@@ -1,5 +1,12 @@
 # @trigger.dev/sdk
 
+## 3.0.0-beta.4
+
+### Patch Changes
+
+- @trigger.dev/core@3.0.0-beta.4
+- @trigger.dev/core-backend@3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ### Patch Changes

packages/trigger-sdk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sdk",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "trigger.dev Node.JS SDK",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -48,8 +48,8 @@
     "@opentelemetry/api": "^1.8.0",
     "@opentelemetry/api-logs": "^0.48.0",
     "@opentelemetry/semantic-conventions": "^1.22.0",
-    "@trigger.dev/core": "workspace:^3.0.0-beta.3",
-    "@trigger.dev/core-backend": "workspace:^3.0.0-beta.3",
+    "@trigger.dev/core": "workspace:^3.0.0-beta.4",
+    "@trigger.dev/core-backend": "workspace:^3.0.0-beta.4",
     "chalk": "^5.2.0",
     "cronstrue": "^2.21.0",
     "debug": "^4.3.4",

packages/yalt/CHANGELOG.md

@@ -1,5 +1,7 @@
 # @trigger.dev/yalt
 
+## 3.0.0-beta.4
+
 ## 3.0.0-beta.3
 
 ## 3.0.0-beta.2

packages/yalt/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/yalt",
-  "version": "3.0.0-beta.3",
+  "version": "3.0.0-beta.4",
   "description": "yalt.dev client library",
   "license": "MIT",
   "main": "./dist/index.js",

pnpm-lock.yaml

@@ -818,10 +818,10 @@ importers:
   integrations/airtable:
     dependencies:
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       airtable:
         specifier: ^0.12.1
@@ -861,10 +861,10 @@ importers:
         specifier: ^12.0.10
         version: 12.0.10
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       octokit:
         specifier: ^3.1.2
@@ -904,10 +904,10 @@ importers:
         specifier: ^8.0.0
         version: 8.0.0
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       zod:
         specifier: 3.22.3
@@ -935,10 +935,10 @@ importers:
   integrations/openai:
     dependencies:
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       openai:
         specifier: ^4.16.1
@@ -978,10 +978,10 @@ importers:
         specifier: ^2.7.0
         version: 2.7.0
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
     devDependencies:
       '@trigger.dev/tsconfig':
@@ -1006,10 +1006,10 @@ importers:
   integrations/replicate:
     dependencies:
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       replicate:
         specifier: ^0.18.1
@@ -1040,10 +1040,10 @@ importers:
   integrations/resend:
     dependencies:
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       resend:
         specifier: ^2.1.0
@@ -1074,10 +1074,10 @@ importers:
         specifier: ^7.7.0
         version: 7.7.0
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
     devDependencies:
       '@trigger.dev/tsconfig':
@@ -1105,10 +1105,10 @@ importers:
         specifier: ^8.0.2
         version: 8.0.2
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       zod:
         specifier: 3.22.3
@@ -1139,7 +1139,7 @@ importers:
         specifier: ^6.8.1
         version: 6.8.1
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       zod:
         specifier: 3.22.3
@@ -1167,10 +1167,10 @@ importers:
   integrations/stripe:
     dependencies:
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       stripe:
         specifier: ^12.14.0
@@ -1204,10 +1204,10 @@ importers:
         specifier: ^2.26.0
         version: 2.31.0
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       supabase-management-js:
         specifier: ^1.0.0
@@ -1238,10 +1238,10 @@ importers:
   integrations/typeform:
     dependencies:
       '@trigger.dev/integration-kit':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/integration-kit
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../../packages/trigger-sdk
       '@typeform/api-client':
         specifier: ^1.8.0
@@ -1269,7 +1269,7 @@ importers:
   packages/astro:
     dependencies:
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../trigger-sdk
       debug:
         specifier: ^4.3.4
@@ -1484,7 +1484,7 @@ importers:
         specifier: ^1.22.0
         version: 1.22.0
       '@trigger.dev/core':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../core
       '@types/degit':
         specifier: ^2.8.3
@@ -1932,7 +1932,7 @@ importers:
         version: 4.18.2
     devDependencies:
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../trigger-sdk
       '@trigger.dev/tsconfig':
         specifier: workspace:*
@@ -2027,7 +2027,7 @@ importers:
         version: 4.3.4(supports-color@8.1.1)
     devDependencies:
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../trigger-sdk
       '@trigger.dev/tsconfig':
         specifier: workspace:*
@@ -2060,7 +2060,7 @@ importers:
   packages/nextjs:
     dependencies:
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../trigger-sdk
       debug:
         specifier: ^4.3.4
@@ -2146,7 +2146,7 @@ importers:
         specifier: 5.0.0-beta.2
         version: 5.0.0-beta.2(react@18.2.0)
       '@trigger.dev/core':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../core
       debug:
         specifier: ^4.3.4
@@ -2189,7 +2189,7 @@ importers:
   packages/remix:
     dependencies:
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../trigger-sdk
       debug:
         specifier: ^4.3.4
@@ -2226,7 +2226,7 @@ importers:
   packages/sveltekit:
     dependencies:
       '@trigger.dev/sdk':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../trigger-sdk
       debug:
         specifier: ^4.3.4
@@ -2300,10 +2300,10 @@ importers:
         specifier: ^1.22.0
         version: 1.22.0
       '@trigger.dev/core':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../core
       '@trigger.dev/core-backend':
-        specifier: workspace:^3.0.0-beta.3
+        specifier: workspace:^3.0.0-beta.4
         version: link:../core-backend
       chalk:
         specifier: ^5.2.0