chore: Update version for release (#794)

* chore: Update version for release

* Update lockfile

---------

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

apps/proxy/CHANGELOG.md

@@ -1,5 +1,36 @@
 # proxy
 
+## 0.0.11
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.5
+
+## 0.0.10
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.4
+
+## 0.0.9
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.3
+
+## 0.0.8
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.2
+
+## 0.0.7
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/core@2.3.1
+
 ## 0.0.6
 
 ### Patch Changes

apps/proxy/package.json

@@ -1,6 +1,6 @@
 {
   "name": "proxy",
-  "version": "0.0.6",
+  "version": "0.0.11",
   "private": true,
   "scripts": {
     "deploy": "wrangler deploy",

apps/webapp/app/services/db/pgListen.server.ts

@@ -1,9 +1,9 @@
+import { Logger } from "@trigger.dev/core-backend";
 import type { PoolClient } from "pg";
 import { z } from "zod";
-import { Logger } from "@trigger.dev/core";
 import { logger } from "~/services/logger.server";
-import { NotificationCatalog, NotificationChannel, notificationCatalog } from "./types";
 import { safeJsonParse } from "~/utils/json";
+import { NotificationCatalog, NotificationChannel, notificationCatalog } from "./types";
 
 export class PgListenService {
   #poolClient: PoolClient;

apps/webapp/app/services/endpointApi.server.ts

@@ -123,6 +123,7 @@ export class EndpointApi {
         "x-trigger-api-key": this.apiKey,
         "x-trigger-action": "INDEX_ENDPOINT",
       },
+      redirect: "manual",
     });
 
     return {

apps/webapp/app/services/endpoints/performEndpointIndexService.ts

@@ -13,6 +13,7 @@ import { fromZodError } from "zod-validation-error";
 import { IndexEndpointStats } from "@trigger.dev/core";
 import { RegisterHttpEndpointService } from "../triggers/registerHttpEndpoint.server";
 import { RegisterWebhookService } from "../triggers/registerWebhook.server";
+import { EndpointIndex } from "@trigger.dev/database";
 
 export class PerformEndpointIndexService {
   #prismaClient: PrismaClient;
@@ -29,7 +30,7 @@ export class PerformEndpointIndexService {
     this.#prismaClient = prismaClient;
   }
 
-  public async call(id: string) {
+  public async call(id: string, redirectCount = 0): Promise<EndpointIndex> {
     const endpointIndex = await this.#prismaClient.endpointIndex.update({
       where: {
         id,
@@ -66,6 +67,39 @@ export class PerformEndpointIndexService {
       });
     }
 
+    if (isRedirect(response.status)) {
+      // Update the endpoint URL with the response.headers.location
+      logger.debug("Endpoint is redirecting", {
+        headers: Object.fromEntries(response.headers.entries()),
+      });
+
+      const location = response.headers.get("location");
+
+      if (!location) {
+        return updateEndpointIndexWithError(this.#prismaClient, id, {
+          message: `Endpoint ${endpointIndex.endpoint.url} is redirecting but no location header is present`,
+        });
+      }
+
+      if (redirectCount > 5) {
+        return updateEndpointIndexWithError(this.#prismaClient, id, {
+          message: `Endpoint ${endpointIndex.endpoint.url} is redirecting too many times`,
+        });
+      }
+
+      await this.#prismaClient.endpoint.update({
+        where: {
+          id: endpointIndex.endpoint.id,
+        },
+        data: {
+          url: location,
+        },
+      });
+
+      // Re-run the endpoint index
+      return await this.call(id, redirectCount + 1);
+    }
+
     if (response.status === 401) {
       const body = await safeBodyFromResponse(response, errorParser);
 
@@ -378,3 +412,10 @@ async function updateEndpointIndexWithError(
     },
   });
 }
+
+const redirectStatus = [301, 302, 303, 307, 308];
+const redirectStatusSet = new Set(redirectStatus);
+
+function isRedirect(status: number) {
+  return redirectStatusSet.has(status);
+}

apps/webapp/app/services/logger.server.ts

@@ -1,5 +1,5 @@
-import type { LogLevel } from "@trigger.dev/core";
-import { Logger } from "@trigger.dev/core";
+import type { LogLevel } from "@trigger.dev/core-backend";
+import { Logger } from "@trigger.dev/core-backend";
 import { sensitiveDataReplacer } from "./sensitiveDataReplacer";
 import { AsyncLocalStorage } from "async_hooks";
 

apps/webapp/app/services/runs/performRunExecutionV3.server.ts

@@ -1045,20 +1045,24 @@ export class PerformRunExecutionV3Service {
       return await this.#failRunExecution(this.#prismaClient, run, output);
     }
 
-    await this.#prismaClient.jobRun.update({
+    const updatedJob = await this.#prismaClient.jobRun.update({
       where: { id: run.id },
       data: {
         status: "WAITING_TO_EXECUTE",
-        executionDuration: {
-          increment: durationInMs,
-        },
-        executionCount: {
+        executionFailureCount: {
           increment: 1,
         },
       },
     });
 
-    await ResumeRunService.enqueue(run, this.#prismaClient);
+    if (updatedJob.executionFailureCount >= 10) {
+      return await this.#failRunExecution(this.#prismaClient, run, output);
+    }
+
+    // Use the job.executionFailureCount to determine how long to wait before retrying, using an exponential backoff
+    const runAt = new Date(Date.now() + Math.pow(1.5, updatedJob.executionFailureCount) * 500); // 500ms, 750ms, 1125ms, 1687ms, 2531ms, 3796ms, 5694ms, 8541ms, 12812ms, 19218ms
+
+    await ResumeRunService.enqueue(run, this.#prismaClient, runAt);
   }
 
   async #failRunExecution(

apps/webapp/package.json

@@ -9,6 +9,7 @@
     "build:remix": "remix build",
     "build:server": "esbuild --platform=node --format=cjs ./server.ts --outdir=build",
     "dev": "cross-env PORT=3030 remix dev",
+    "dev:manual": "cross-env PORT=3030 remix dev -c \"node ./build/server.js\"",
     "format": "prettier --write .",
     "lint": "eslint --cache --cache-location ./node_modules/.cache/eslint .",
     "start": "cross-env NODE_ENV=production node --max-old-space-size=8192 ./build/server.js",
@@ -188,4 +189,4 @@
   "engines": {
     "node": ">=16.0.0"
   }
-}
+}

docs/documentation/quickstarts/hono.mdx

@@ -60,7 +60,7 @@ Our `@trigger.dev/hono` package provides two different ways of configuring the n
 
 ### Cloudflare Workers
 
-Becase environment variables in Cloudflare Workers aren't available in the global scope, but are instead available only inside the fetch handler, we need to use the `addMiddleware` function to add the necessary middleware to your Hono app.
+Because environment variables in Cloudflare Workers aren't available in the global scope, but are instead available only inside the fetch handler, we need to use the `addMiddleware` function to add the necessary middleware to your Hono app.
 
 ```ts
 import { Hono } from "hono";

integrations/airtable/CHANGELOG.md

@@ -1,5 +1,44 @@
 # @trigger.dev/airtable
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- 0f9f0102: Named exports don't work because Airtable is a CommonJS module
+  - @trigger.dev/integration-kit@2.3.3
+  - @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- 0c14e4cd: Fixed importing package subpath
+  - @trigger.dev/integration-kit@2.3.2
+  - @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/airtable/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/airtable",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "airtable": "^0.12.1",
     "zod": "3.22.3"
   },

integrations/airtable/src/base.ts

@@ -1,14 +1,13 @@
-import { DisplayProperty, IOWithIntegrations, IntegrationTaskKey } from "@trigger.dev/sdk";
-import { FieldSet, Records, SelectOptions } from "airtable";
-import { AirtableFieldSet, AirtableRecord, AirtableRunTask, CreateAirtableRecord } from ".";
-import { QueryParams } from "airtable/lib/query_params";
+import { DisplayProperty, IntegrationTaskKey } from "@trigger.dev/sdk";
+import AirtableSDK from "airtable";
+import { AirtableFieldSet, AirtableRecord, AirtableRunTask } from ".";
 
 type TableParams<Params extends Record<string, unknown>> = {
   tableName: string;
 } & Params;
 
 export type AirtableRecordsParams = TableParams<{}>;
-export type AirtableRecords = Records<FieldSet>;
+export type AirtableRecords = AirtableSDK.Records<AirtableSDK.FieldSet>;
 
 export class Base {
   constructor(
@@ -32,7 +31,7 @@ export class Table<TFields extends AirtableFieldSet> {
     this.tableName = tableName;
   }
 
-  getRecords(key: IntegrationTaskKey, params?: SelectOptions<TFields>) {
+  getRecords(key: IntegrationTaskKey, params?: AirtableSDK.SelectOptions<TFields>) {
     return this.runTask(
       key,
       async (client) => {

integrations/airtable/src/index.ts

@@ -10,19 +10,12 @@ import {
   type RunTaskOptions,
   type TriggerIntegration,
 } from "@trigger.dev/sdk";
-import AirtableSDK, { Error as AirtableApiError } from "airtable";
+import AirtableSDK from "airtable";
 import { Base } from "./base";
-import * as events from "./events";
-import {
-  WebhookChangeType,
-  WebhookDataType,
-  Webhooks,
-  createWebhookSource,
-  createWebhookTrigger,
-} from "./webhooks";
+import { Webhooks, createWebhookSource } from "./webhooks";
 
-export * from "./types";
 export * from "./base";
+export * from "./types";
 
 export type AirtableIntegrationOptions = {
   /** An ID for this client  */
@@ -138,12 +131,12 @@ export class Airtable implements TriggerIntegration {
   }
 }
 
-function isAirtableApiError(error: unknown): error is AirtableApiError {
+function isAirtableApiError(error: unknown): error is AirtableSDK.Error {
   if (typeof error !== "object" || error === null) {
     return false;
   }
 
-  const airtableError = error as AirtableApiError;
+  const airtableError = error as AirtableSDK.Error;
 
   return (
     typeof airtableError.error === "string" &&

integrations/airtable/src/types.ts

@@ -1,5 +1,3 @@
-import { Prettify } from "@trigger.dev/integration-kit";
-
 export type AirtableFieldSet = {
   [key: string]:
     | undefined

integrations/airtable/src/webhooks.ts

@@ -1,11 +1,11 @@
 import { EventFilter, IntegrationTaskKey, verifyRequestSignature } from "@trigger.dev/sdk";
-import AirtableSDK, { Error as AirtableApiError } from "airtable";
+import AirtableSDK from "airtable";
 import { z } from "zod";
 import * as events from "./events";
 import { Airtable, AirtableRunTask } from "./index";
 import { ListWebhooksResponse, ListWebhooksResponseSchema } from "./schemas";
-import { WebhookSource, WebhookTrigger } from "@trigger.dev/sdk/triggers/webhook";
-import { registerJobNamespace } from "@trigger.dev/integration-kit/webhooks";
+import { WebhookSource, WebhookTrigger } from "@trigger.dev/sdk";
+import { registerJobNamespace } from "@trigger.dev/integration-kit";
 import { Buffer } from "node:buffer";
 
 const WebhookFromSourceSchema = z.union([
@@ -451,7 +451,7 @@ async function handleWebhookError(response: Response, errorType: string) {
   const parsedErrorBody = AirtableErrorBodySchema.safeParse(rawErrorBody);
 
   if (!parsedErrorBody.success) {
-    throw new AirtableApiError(
+    throw new AirtableSDK.Error(
       `${errorType}_PARSE_ERROR`,
       `${response.statusText}:\n${rawErrorBody}`,
       response.status
@@ -460,5 +460,5 @@ async function handleWebhookError(response: Response, errorType: string) {
 
   const { type, message } = parsedErrorBody.data;
 
-  throw new AirtableApiError(type, message ?? response.statusText, response.status);
+  throw new AirtableSDK.Error(type, message ?? response.statusText, response.status);
 }

integrations/github/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/github
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/github/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/github",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "description": "The official GitHub integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -29,8 +29,8 @@
     "@octokit/request": "^6.2.5",
     "@octokit/request-error": "^4.0.1",
     "@octokit/webhooks": "^10.4.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "octokit": "^2.0.14",
     "zod": "3.22.3"
   },

integrations/linear/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/linear
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/linear/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/linear",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "zod": "3.22.3"
   },
   "engines": {

integrations/openai/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/slack
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/openai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/openai",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.0"
+    "@trigger.dev/sdk": "workspace:^2.3.5",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5"
   },
   "engines": {
     "node": ">=18.0.0"

integrations/plain/CHANGELOG.md

@@ -1,5 +1,43 @@
 # @trigger.dev/plain
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- 0c14e4cd: Fixed importing package subpath
+  - @trigger.dev/integration-kit@2.3.2
+  - @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/plain/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/plain",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "@team-plain/typescript-sdk": "^2.7.0"
   },
   "engines": {

integrations/plain/src/types.ts

@@ -1,5 +1,5 @@
 import { PlainClient } from "@team-plain/typescript-sdk";
-import { Prettify } from "@trigger.dev/integration-kit/prettify";
+import { Prettify } from "@trigger.dev/integration-kit";
 
 export type PlainSDK = InstanceType<typeof PlainClient>;
 

integrations/replicate/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/replicate
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/replicate/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/replicate",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "replicate": "^0.18.1",
     "zod": "3.22.3"
   },

integrations/resend/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/resend
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/resend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/resend",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "resend": "^2.0.0"
   },
   "engines": {

integrations/sendgrid/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/sendgrid
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/sendgrid/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sendgrid",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.0"
+    "@trigger.dev/sdk": "workspace:^2.3.5",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5"
   },
   "engines": {
     "node": ">=16.8.0"

integrations/shopify/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/shopify
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/shopify/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/shopify",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.0",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
     "zod": "3.22.3"
   },
   "engines": {

integrations/slack/CHANGELOG.md

@@ -1,5 +1,37 @@
 # @trigger.dev/slack
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/slack/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/slack",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "zod": "3.22.3"
   },
   "engines": {

integrations/stripe/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/stripe
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/stripe/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/stripe",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "stripe": "^12.14.0",
     "zod": "3.22.3"
   },

integrations/supabase/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/supabase
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/supabase/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/supabase",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "supabase-management-js": "^1.0.0",
     "zod": "3.22.3"
   },

integrations/typeform/CHANGELOG.md

@@ -1,5 +1,42 @@
 # @trigger.dev/typeform
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.5
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/integration-kit@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/integration-kit@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

integrations/typeform/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/typeform",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
-    "@trigger.dev/sdk": "workspace:^2.3.0",
+    "@trigger.dev/integration-kit": "workspace:^2.3.5",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "@typeform/api-client": "^1.8.0",
     "zod": "3.22.3"
   },

packages/astro/CHANGELOG.md

@@ -1,5 +1,37 @@
 # @trigger.dev/astro
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### 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": "2.3.0",
+  "version": "2.3.5",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "files": [
@@ -20,7 +20,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.0"
+    "@trigger.dev/sdk": "workspace:^2.3.5"
   },
   "devDependencies": {
     "astro": "^3.0.12",

packages/cli/CHANGELOG.md

@@ -1,5 +1,36 @@
 # create-trigger
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/core@2.3.1
+
 ## 2.3.0
 
 ### Patch Changes

packages/cli/package.json

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

packages/core-backend/CHANGELOG.md

@@ -1,5 +1,19 @@
 # @trigger.dev/core-backend
 
+## 2.3.5
+
+## 2.3.4
+
+## 2.3.3
+
+## 2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- f3efcc0c: Moved Logger to core-backend, no longer importing node:buffer in core/react
+
 ## 2.3.0
 
 ### Minor Changes

packages/core-backend/package.json

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

packages/core-backend/src/index.ts

@@ -1 +1,2 @@
 export * from "./bloom";
+export * from "./logger";

packages/core-backend/src/logger.ts

@@ -196,11 +196,5 @@ function prettyPrintBytes(value: unknown): string {
 function getSizeInBytes(value: unknown) {
   const jsonString = JSON.stringify(value);
 
-  if (typeof window === "undefined") {
-    // Node.js environment
-    return Buffer.byteLength(jsonString, "utf8");
-  } else {
-    // Browser environment
-    return new TextEncoder().encode(jsonString).length;
-  }
+  return Buffer.byteLength(jsonString, "utf8");
 }

packages/core/CHANGELOG.md

@@ -1,5 +1,19 @@
 # internal-platform
 
+## 2.3.5
+
+## 2.3.4
+
+## 2.3.3
+
+## 2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- f3efcc0c: Moved Logger to core-backend, no longer importing node:buffer in core/react
+
 ## 2.3.0
 
 ### Minor Changes

packages/core/package.json

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

packages/core/src/index.ts

@@ -1,4 +1,3 @@
-export * from "./logger";
 export * from "./schemas";
 export * from "./types";
 export * from "./utils";

packages/database/prisma/migrations/20231206205233_add_execution_failure_count_to_runs/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "JobRun" ADD COLUMN     "executionFailureCount" INTEGER NOT NULL DEFAULT 0;

packages/database/prisma/schema.prisma

@@ -784,8 +784,9 @@ model JobRun {
   timedOutAt     DateTime?
   timedOutReason String?
 
-  executionCount    Int @default(0)
-  executionDuration Int @default(0)
+  executionCount        Int @default(0)
+  executionFailureCount Int @default(0)
+  executionDuration     Int @default(0)
 
   isTest     Boolean @default(false)
   preprocess Boolean @default(false)

packages/eslint-plugin/CHANGELOG.md

@@ -1,5 +1,15 @@
 # @trigger.dev/eslint-plugin
 
+## 2.3.5
+
+## 2.3.4
+
+## 2.3.3
+
+## 2.3.2
+
+## 2.3.1
+
 ## 2.3.0
 
 ## 2.2.11

packages/eslint-plugin/package.json

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

packages/express/CHANGELOG.md

@@ -1,5 +1,37 @@
 # @trigger.dev/express
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/express/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/express",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "@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:^2.3.0"
+    "@trigger.dev/sdk": "workspace:^2.3.5"
   },
   "dependencies": {
     "debug": "^4.3.4",

packages/hono/CHANGELOG.md

@@ -1,5 +1,37 @@
 # @trigger.dev/hono
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### Patch Changes

packages/hono/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/hono",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0"
+    "@trigger.dev/sdk": "workspace:^2.3.5"
   },
   "devDependencies": {
     "@trigger.dev/tsconfig": "workspace:*",

packages/integration-kit/CHANGELOG.md

@@ -1,5 +1,36 @@
 # @trigger.dev/integration-kit
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/core@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/integration-kit/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/integration-kit",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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,37 @@
 # @trigger.dev/nestjs
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/nestjs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/nestjs",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
+    "@trigger.dev/sdk": "workspace:^2.3.5",
     "@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:^2.3.0"
+    "@trigger.dev/sdk": "workspace:^2.3.5"
   },
   "dependencies": {
     "@nestjs/common": "^10.2.4",

packages/nextjs/CHANGELOG.md

@@ -1,5 +1,37 @@
 # @trigger.dev/nextjs
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/nextjs/package.json

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

packages/react/CHANGELOG.md

@@ -1,5 +1,36 @@
 # @trigger.dev/react
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/core@2.3.1
+
 ## 2.3.0
 
 ### Patch Changes

packages/react/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/react",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "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:^2.3.0",
+    "@trigger.dev/core": "workspace:^2.3.5",
     "debug": "^4.3.4",
     "zod": "3.22.3"
   },

packages/remix/CHANGELOG.md

@@ -1,5 +1,37 @@
 # @trigger.dev/remix
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/remix/package.json

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

packages/sveltekit/CHANGELOG.md

@@ -1,5 +1,37 @@
 # @trigger.dev/sveltekit
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/sveltekit/package.json

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

packages/testing/CHANGELOG.md

@@ -1,5 +1,43 @@
 # @trigger.dev/testing
 
+## 2.3.5
+
+### Patch Changes
+
+- fc31c6c0: Fix test isolation by restoring the original run function
+  - @trigger.dev/core@2.3.5
+  - @trigger.dev/sdk@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- Updated dependencies [6a3c563f]
+  - @trigger.dev/sdk@2.3.4
+  - @trigger.dev/core@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.3
+- @trigger.dev/sdk@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.2
+- @trigger.dev/sdk@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/sdk@2.3.1
+  - @trigger.dev/core@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/testing/README.md

@@ -76,7 +76,7 @@ expect(testRun.output).toEqual({ bar: "baz" });
 
 ## More information
 
-See the official [Trigger.dev Unit Testing Reference](https://github.com/triggerdotdev/trigger.dev/references/unit-testing/) for a working setup with Vitest.
+See the official [Trigger.dev Unit Testing Reference](https://github.com/triggerdotdev/trigger.dev/tree/main/references/unit-testing/) for a working setup with Vitest.
 
 ## License
 

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": "2.3.0",
+  "version": "2.3.5",
   "license": "MIT",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/testing/src/index.ts

@@ -192,18 +192,22 @@ export const createJobTester =
       return run(payload, io, ctx);
     };
 
-    const request = buildRequest("EXECUTE_JOB", client!.apiKey() ?? "", {
-      body: buildRequestBody(eventLog, job),
-      jobId: job.id,
-    });
-    const requestResult = await client!.handleRequest(request);
+    try {
+      const request = buildRequest("EXECUTE_JOB", client!.apiKey() ?? "", {
+        body: buildRequestBody(eventLog, job),
+        jobId: job.id,
+      });
+      const requestResult = await client!.handleRequest(request);
 
-    const { output, status, ...rest } = requestResult.body;
+      const { output, status, ...rest } = requestResult.body;
 
-    return {
-      output,
-      status,
-      tasks,
-      ...rest,
-    };
+      return {
+        output,
+        status,
+        tasks,
+        ...rest,
+      };
+    } finally {
+      job.options.run = run;
+    }
   };

packages/testing/tests/createJobTester.test.ts

@@ -1,7 +1,7 @@
 import { TriggerClient, eventTrigger } from "@trigger.dev/sdk";
 import { Stripe } from "@trigger.dev/stripe";
 import { toHaveSucceeded, createJobTester } from "../src";
-import { expect, test, vi } from "vitest";
+import { describe, expect, test, vi } from "vitest";
 import { z } from "zod";
 
 expect.extend({ toHaveSucceeded });
@@ -98,3 +98,49 @@ test("stripe integration", async () => {
   // job run has expected output
   expect(testRun.output).toEqual({ id: "charge_1234" });
 });
+
+describe("isolation test", () => {
+  const jobToTest = client.defineJob({
+    id: "isolation-test",
+    name: "isolation-test",
+    version: "0.1.0",
+    trigger: eventTrigger({
+      name: "isolation-test",
+    }),
+    run: async (payload, io, ctx) => {
+      const number = await io.runTask("get-number", async () => {
+        return 42;
+      });
+      return { number };
+    },
+  });
+
+  test("run 1", async () => {
+    const testRun = await testJob(jobToTest, {
+      tasks: {
+        "get-number": 1,
+      },
+      payload: 1
+    });
+
+    // job run was successful
+    expect(testRun).toHaveSucceeded();
+
+    // job run has expected output
+    expect(testRun.output.number).toEqual(1);
+  });
+
+  test("run 2", async () => {
+    const testRun = await testJob(jobToTest, {
+      tasks: {
+        "get-number": 2,
+      },
+    });
+
+    // job run was successful
+    expect(testRun).toHaveSucceeded();
+
+    // job run has expected output
+    expect(testRun.output.number).toEqual(2);
+  });
+});

packages/testing/tsconfig.json

@@ -4,18 +4,16 @@
     "noEmit": true,
     "lib": ["dom"],
     "paths": {
+      "@/*": ["./src/*"],
+      "@trigger.dev/core": ["../../packages/core/src/index"],
+      "@trigger.dev/core/*": ["../../packages/core/src/*"],
+      "@trigger.dev/sdk": ["../../packages/trigger-sdk/src/index"],
+      "@trigger.dev/sdk/*": ["../../packages/trigger-sdk/src/*"],
+      "@trigger.dev/stripe": ["../../integrations/stripe/src/index"],
+      "@trigger.dev/stripe/*": ["../../integrations/stripe/src/*"],
       "@trigger.dev/tsup/*": ["../../config-packages/tsup/src/*"],
       "@trigger.dev/tsup": ["../../config-packages/tsup/src/index"]
     }
   },
-  "paths": {
-    "@/*": ["./src/*"],
-    "@trigger.dev/core": ["../../packages/core/src/index"],
-    "@trigger.dev/core/*": ["../../packages/core/src/*"],
-    "@trigger.dev/sdk": ["../../packages/trigger-sdk/src/index"],
-    "@trigger.dev/sdk/*": ["../../packages/trigger-sdk/src/*"],
-    "@trigger.dev/stripe": ["../../integrations/stripe/src/index"],
-    "@trigger.dev/stripe/*": ["../../integrations/stripe/src/*"]
-  },
   "exclude": ["node_modules"]
 }

packages/trigger-sdk/CHANGELOG.md

@@ -1,5 +1,43 @@
 # @trigger.dev/sdk
 
+## 2.3.5
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.5
+- @trigger.dev/core-backend@2.3.5
+
+## 2.3.4
+
+### Patch Changes
+
+- 6a3c563f: Fixed Job.attachToClient
+  - @trigger.dev/core@2.3.4
+  - @trigger.dev/core-backend@2.3.4
+
+## 2.3.3
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.3
+- @trigger.dev/core-backend@2.3.3
+
+## 2.3.2
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.2
+- @trigger.dev/core-backend@2.3.2
+
+## 2.3.1
+
+### Patch Changes
+
+- f3efcc0c: Moved Logger to core-backend, no longer importing node:buffer in core/react
+- Updated dependencies [f3efcc0c]
+  - @trigger.dev/core-backend@2.3.1
+  - @trigger.dev/core@2.3.1
+
 ## 2.3.0
 
 ### Minor Changes

packages/trigger-sdk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sdk",
-  "version": "2.3.0",
+  "version": "2.3.5",
   "description": "trigger.dev Node.JS SDK",
   "license": "MIT",
   "main": "./dist/index.js",
@@ -30,8 +30,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/core": "workspace:^2.3.0",
-    "@trigger.dev/core-backend": "workspace:^2.3.0",
+    "@trigger.dev/core": "workspace:^2.3.5",
+    "@trigger.dev/core-backend": "workspace:^2.3.5",
     "chalk": "^5.2.0",
     "cronstrue": "^2.21.0",
     "debug": "^4.3.4",

packages/trigger-sdk/src/apiClient.ts

@@ -20,8 +20,6 @@ import {
   JobRunStatusRecordSchema,
   KeyValueStoreResponseBody,
   KeyValueStoreResponseBodySchema,
-  LogLevel,
-  Logger,
   RegisterScheduleResponseBodySchema,
   RegisterSourceEventSchemaV2,
   RegisterSourceEventV2,
@@ -40,6 +38,7 @@ import {
   assertExhaustive,
   urlWithSearchParams,
 } from "@trigger.dev/core";
+import { LogLevel, Logger } from "@trigger.dev/core-backend";
 import { env } from "node:process";
 
 import { z } from "zod";

packages/trigger-sdk/src/io.ts

@@ -11,8 +11,6 @@ import {
   FetchTimeoutOptions,
   InitialStatusUpdate,
   IntervalOptions,
-  LogLevel,
-  Logger,
   RunTaskOptions,
   SendEvent,
   SendEventOptions,
@@ -21,6 +19,7 @@ import {
   UpdateWebhookBody,
   supportsFeature,
 } from "@trigger.dev/core";
+import { LogLevel, Logger } from "@trigger.dev/core-backend";
 import { BloomFilter } from "@trigger.dev/core-backend";
 import { AsyncLocalStorage } from "node:async_hooks";
 import { webcrypto } from "node:crypto";

packages/trigger-sdk/src/job.ts

@@ -3,11 +3,11 @@ import {
   IntegrationConfig,
   InvokeOptions,
   JobMetadata,
-  LogLevel,
   Prettify,
   RunNotification,
   SuccessfulRunNotification,
 } from "@trigger.dev/core";
+import { LogLevel } from "@trigger.dev/core-backend";
 import { ConcurrencyLimit } from "./concurrencyLimit";
 import { IOWithIntegrations, TriggerIntegration } from "./integrations";
 import { runLocalStorage } from "./runLocalStorage";
@@ -121,8 +121,8 @@ export class Job<
    * Attaches the job to a client. This is called automatically when you define a job using `client.defineJob()`.
    */
   attachToClient(client: TriggerClient) {
-    this.client = client;
-    this.trigger.attachToJob(client, this);
+    client.attach(this);
+    return this;
   }
 
   get id() {
@@ -185,8 +185,8 @@ export class Job<
         typeof this.options.concurrencyLimit === "number"
           ? this.options.concurrencyLimit
           : typeof this.options.concurrencyLimit === "object"
-          ? { id: this.options.concurrencyLimit.id, limit: this.options.concurrencyLimit.limit }
-          : undefined,
+            ? { id: this.options.concurrencyLimit.id, limit: this.options.concurrencyLimit.limit }
+            : undefined,
     };
   }
 

packages/trigger-sdk/src/triggerClient.ts

@@ -17,8 +17,6 @@ import {
   IntegrationConfig,
   InvokeOptions,
   JobMetadata,
-  LogLevel,
-  Logger,
   NormalizedResponse,
   PreprocessRunBody,
   PreprocessRunBodySchema,
@@ -46,8 +44,12 @@ import {
   WebhookMetadata,
   WebhookSourceRequestHeadersSchema,
 } from "@trigger.dev/core";
+import { LogLevel, Logger } from "@trigger.dev/core-backend";
+import EventEmitter from "node:events";
 import { env } from "node:process";
+import * as packageJson from "../package.json";
 import { ApiClient } from "./apiClient";
+import { ConcurrencyLimit, ConcurrencyLimitOptions } from "./concurrencyLimit";
 import {
   AutoYieldExecutionError,
   AutoYieldWithCompletedTaskExecutionError,
@@ -65,18 +67,21 @@ import { IO, IOStats } from "./io";
 import { createIOWithIntegrations } from "./ioWithIntegrations";
 import { Job, JobOptions } from "./job";
 import { runLocalStorage } from "./runLocalStorage";
+import { KeyValueStore } from "./store/keyValueStore";
 import { DynamicTrigger, DynamicTriggerOptions } from "./triggers/dynamic";
 import { EventTrigger } from "./triggers/eventTrigger";
 import { ExternalSource } from "./triggers/externalSource";
 import { DynamicIntervalOptions, DynamicSchedule } from "./triggers/scheduled";
-import type {
-  EventSpecification,
-  NotificationsEventEmitter,
-  Trigger,
-  TriggerContext,
-  TriggerPreprocessContext,
-  VerifyResult,
+import { WebhookDeliveryContext, WebhookSource } from "./triggers/webhook";
+import {
+  type EventSpecification,
+  type NotificationsEventEmitter,
+  type Trigger,
+  type TriggerContext,
+  type TriggerPreprocessContext,
+  type VerifyResult,
 } from "./types";
+import { formatSchemaErrors } from "./utils/formatSchemaErrors";
 
 const parseRequestPayload = (rawPayload: any) => {
   const result = RequestWithRawBodySchema.safeParse(rawPayload);
@@ -92,14 +97,6 @@ const parseRequestPayload = (rawPayload: any) => {
   });
 };
 
-const deliverWebhookEvent = (key: string): EventSpecification<Request> => ({
-  name: `${DELIVER_WEBHOOK_REQUEST}.${key}`,
-  title: "Deliver Webhook",
-  source: "internal",
-  icon: "mail-fast",
-  parsePayload: parseRequestPayload,
-});
-
 const registerWebhookEvent = (key: string): EventSpecification<RegisterWebhookPayload> => ({
   name: `${REGISTER_WEBHOOK}.${key}`,
   title: "Register Webhook",
@@ -116,13 +113,6 @@ const registerSourceEvent: EventSpecification<RegisterSourceEventV2> = {
   parsePayload: RegisterSourceEventSchemaV2.parse,
 };
 
-import EventEmitter from "node:events";
-import * as packageJson from "../package.json";
-import { ConcurrencyLimit, ConcurrencyLimitOptions } from "./concurrencyLimit";
-import { KeyValueStore } from "./store/keyValueStore";
-import { WebhookDeliveryContext, WebhookSource } from "./triggers/webhook";
-import { formatSchemaErrors } from "./utils/formatSchemaErrors";
-
 export type TriggerClientOptions = {
   /** The `id` property is used to uniquely identify the client.
    */
@@ -749,7 +739,8 @@ export class TriggerClient {
 
   attach(job: Job<Trigger<any>, any>): void {
     this.#registeredJobs[job.id] = job;
-    job.attachToClient(this);
+    job.trigger.attachToJob(this, job);
+    job.client = this;
   }
 
   attachDynamicTrigger(trigger: DynamicTrigger<any, any>): void {
@@ -1693,15 +1684,15 @@ export class TriggerClient {
         auth:
           resolvedAuth.type === "apiKey"
             ? {
-                type: "apiKey",
-                accessToken: resolvedAuth.token,
-                additionalFields: resolvedAuth.additionalFields,
-              }
+              type: "apiKey",
+              accessToken: resolvedAuth.token,
+              additionalFields: resolvedAuth.additionalFields,
+            }
             : {
-                type: "oauth2",
-                accessToken: resolvedAuth.token,
-                additionalFields: resolvedAuth.additionalFields,
-              },
+              type: "oauth2",
+              accessToken: resolvedAuth.token,
+              additionalFields: resolvedAuth.additionalFields,
+            },
       };
     } catch (resolverError) {
       if (resolverError instanceof Error) {
@@ -1718,9 +1709,8 @@ export class TriggerClient {
 
       return {
         ok: false,
-        error: `Auth could not be resolved for ${
-          integration.id
-        }: auth resolver threw an unknown error: ${JSON.stringify(resolverError)}`,
+        error: `Auth could not be resolved for ${integration.id
+          }: auth resolver threw an unknown error: ${JSON.stringify(resolverError)}`,
       };
     }
   }
@@ -1747,8 +1737,8 @@ export class TriggerClient {
         typeof job.options.concurrencyLimit === "number"
           ? job.options.concurrencyLimit
           : typeof job.options.concurrencyLimit === "object"
-          ? { id: job.options.concurrencyLimit.id, limit: job.options.concurrencyLimit.limit }
-          : undefined,
+            ? { id: job.options.concurrencyLimit.id, limit: job.options.concurrencyLimit.limit }
+            : undefined,
     };
   }
 

packages/trigger-sdk/src/triggers/externalSource.ts

@@ -1,25 +1,25 @@
 import {
+  ConnectionAuth,
   DisplayProperty,
   EventFilter,
   HandleTriggerSource,
   HttpSourceResponseMetadata,
-  Logger,
   NormalizedResponse,
+  Prettify,
   RegisterTriggerSource,
   SendEvent,
+  SerializableJson,
   TriggerMetadata,
   deepMergeFilters,
 } from "@trigger.dev/core";
+import { Logger } from "@trigger.dev/core-backend";
+import type { Buffer } from "buffer";
 import { IOWithIntegrations, TriggerIntegration } from "../integrations";
 import { IO } from "../io";
 import { Job } from "../job";
 import { TriggerClient } from "../triggerClient";
 import type { EventSpecification, SchemaParser, Trigger, TriggerContext } from "../types";
 import { slugifyId } from "../utils";
-import { SerializableJson } from "@trigger.dev/core";
-import { ConnectionAuth } from "@trigger.dev/core";
-import { Prettify } from "@trigger.dev/core";
-import type { Buffer } from "buffer";
 
 export type HttpSourceEvent = {
   url: string;

packages/trigger-sdk/src/types.ts

@@ -2,24 +2,21 @@ import type {
   DisplayProperty,
   EventFilter,
   FailedRunNotification,
-  Logger,
   OverridableRunTaskOptions,
   Prettify,
   RedactString,
   RegisteredOptionsDiff,
-  RunNotificationJobMetadata,
-  RunNotificationRunMetadata,
   RunTaskOptions,
   RuntimeEnvironmentType,
-  ServerTask,
   SourceEventOption,
   SuccessfulRunNotification,
   TriggerMetadata,
 } from "@trigger.dev/core";
+import { Logger } from "@trigger.dev/core-backend";
+import type TypedEmitter from "typed-emitter";
+import { z } from "zod";
 import { Job } from "./job";
 import { TriggerClient } from "./triggerClient";
-import { z } from "zod";
-import type TypedEmitter from "typed-emitter";
 
 export type {
   DisplayProperty,
@@ -124,8 +121,8 @@ export type TypedEventSpecificationExample<TEvent> = {
   id: string;
   name: string;
   icon?: string;
-  payload: TEvent
-}
+  payload: TEvent;
+};
 
 export interface EventSpecification<TEvent extends any, TInvoke extends any = TEvent> {
   name: string | string[];

pnpm-lock.yaml

@@ -397,7 +397,7 @@ importers:
     devDependencies:
       eslint: 8.31.0
       eslint-config-prettier: 8.6.0_eslint@8.31.0
-      eslint-config-turbo: 1.11.0_eslint@8.31.0
+      eslint-config-turbo: 1.11.2_eslint@8.31.0
       eslint-plugin-react: 7.31.8_eslint@8.31.0
       typescript: 4.9.4
 
@@ -425,8 +425,8 @@ importers:
 
   integrations/airtable:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -455,8 +455,8 @@ importers:
       '@octokit/types': ^9.2.3
       '@octokit/webhooks': ^10.4.0
       '@octokit/webhooks-types': ^6.10.0
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -486,8 +486,8 @@ importers:
   integrations/linear:
     specifiers:
       '@linear/sdk': ^8.0.0
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -510,8 +510,8 @@ importers:
 
   integrations/openai:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/jest': ^29.5.3
@@ -540,8 +540,8 @@ importers:
   integrations/plain:
     specifiers:
       '@team-plain/typescript-sdk': ^2.7.0
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -562,8 +562,8 @@ importers:
 
   integrations/replicate:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -587,8 +587,8 @@ importers:
 
   integrations/resend:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -611,8 +611,8 @@ importers:
   integrations/sendgrid:
     specifiers:
       '@sendgrid/mail': ^7.7.0
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -634,8 +634,8 @@ importers:
   integrations/shopify:
     specifiers:
       '@shopify/shopify-api': ^8.0.2
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
@@ -659,7 +659,7 @@ importers:
   integrations/slack:
     specifiers:
       '@slack/web-api': ^6.8.1
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': '18'
@@ -681,8 +681,8 @@ importers:
 
   integrations/stripe:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsup': workspace:*
       '@types/node': 16.x
       rimraf: ^3.0.2
@@ -707,8 +707,8 @@ importers:
   integrations/supabase:
     specifiers:
       '@supabase/supabase-js': ^2.26.0
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/node': 18.x
@@ -733,8 +733,8 @@ importers:
 
   integrations/typeform:
     specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.3.0
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/integration-kit': workspace:^2.3.5
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsup': workspace:*
       '@typeform/api-client': ^1.8.0
       '@types/node': 16.x
@@ -994,7 +994,7 @@ importers:
 
   packages/express:
     specifiers:
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/debug': ^4.1.7
@@ -1064,7 +1064,7 @@ importers:
     specifiers:
       '@nestjs/common': ^10.2.4
       '@remix-run/web-fetch': ^4.3.5
-      '@trigger.dev/sdk': workspace:^2.3.0
+      '@trigger.dev/sdk': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/debug': ^4.1.7
@@ -1123,7 +1123,7 @@ importers:
   packages/react:
     specifiers:
       '@tanstack/react-query': 5.0.0-beta.2
-      '@trigger.dev/core': workspace:^2.3.0
+      '@trigger.dev/core': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@types/debug': ^4.1.7
       '@types/react': 18.2.17
@@ -1226,8 +1226,8 @@ importers:
 
   packages/trigger-sdk:
     specifiers:
-      '@trigger.dev/core': workspace:^2.3.0
-      '@trigger.dev/core-backend': workspace:^2.3.0
+      '@trigger.dev/core': workspace:^2.3.5
+      '@trigger.dev/core-backend': workspace:^2.3.5
       '@trigger.dev/tsconfig': workspace:*
       '@trigger.dev/tsup': workspace:*
       '@types/debug': ^4.1.7
@@ -19146,13 +19146,13 @@ packages:
       eslint: 8.45.0
     dev: true
 
-  /eslint-config-turbo/1.11.0_eslint@8.31.0:
-    resolution: {integrity: sha512-PBiDoO1ZRHBXoydfn/qYazJTwmoRNXdsf3CBg6j7BMVvuAPa39e7ao6KccsDplyLgV2jIjeRtra/q1CUaWs2kg==}
+  /eslint-config-turbo/1.11.2_eslint@8.31.0:
+    resolution: {integrity: sha512-vqbyCH6kCHFoIAWUmGL61c0BfUQNz0XAl2RzAnEkSQ+PLXvEvuV2HsvL51UOzyyElfJlzZuh9T4BvUqb5KR9Eg==}
     peerDependencies:
       eslint: '>6.6.0'
     dependencies:
       eslint: 8.31.0
-      eslint-plugin-turbo: 1.11.0_eslint@8.31.0
+      eslint-plugin-turbo: 1.11.2_eslint@8.31.0
     dev: true
 
   /eslint-doc-generator/1.4.3_eslint@8.45.0:
@@ -19855,8 +19855,8 @@ packages:
       - typescript
     dev: true
 
-  /eslint-plugin-turbo/1.11.0_eslint@8.31.0:
-    resolution: {integrity: sha512-u3GeDFuKUMcQOPi5euJIAivTvJBPMZL62LVrNc4uGksGMYekl7Dl3yGcevcUpebm7XDValyWcw1iHZjUm3DfCg==}
+  /eslint-plugin-turbo/1.11.2_eslint@8.31.0:
+    resolution: {integrity: sha512-U6DX+WvgGFiwEAqtOjm4Ejd9O4jsw8jlFNkQi0ywxbMnbiTie+exF4Z0F/B1ajtjjeZkBkgRnlU+UkoraBN+bw==}
     peerDependencies:
       eslint: '>6.6.0'
     dependencies:

references/job-catalog/src/edge-cases.ts

@@ -1,5 +1,5 @@
 import { createExpressServer } from "@trigger.dev/express";
-import { TriggerClient, invokeTrigger } from "@trigger.dev/sdk";
+import { Job, TriggerClient, invokeTrigger } from "@trigger.dev/sdk";
 import fs from "node:fs";
 import fsPromises from "node:fs/promises";
 
@@ -104,4 +104,14 @@ client.defineJob({
   },
 });
 
+const job = new Job({
+  id: "attach-to-client",
+  name: "Attach to Client",
+  version: "1.0.0",
+  trigger: invokeTrigger(),
+  run: async (payload, io, ctx) => {
+    await io.logger.info("Hello from job", { ctx })
+  },
+}).attachToClient(client);
+
 createExpressServer(client);