Merge branch 'main' into worker-upgrade

This commit is contained in:
nicktrn
2023-12-07 09:57:23 +00:00
75 changed files with 536 additions and 161 deletions
+13
View File
@@ -1,5 +1,18 @@
# proxy
## 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
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "proxy",
"version": "0.0.6",
"version": "0.0.8",
"private": true,
"scripts": {
"deploy": "wrangler deploy",
@@ -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;
+2 -2
View File
@@ -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";
@@ -1053,20 +1053,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(
+16
View File
@@ -1,5 +1,21 @@
# @trigger.dev/airtable
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/airtable",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"airtable": "^0.12.1",
"zod": "3.22.3"
},
+2 -2
View File
@@ -4,8 +4,8 @@ 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([
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/github
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/github",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"octokit": "^2.0.14",
"zod": "3.22.3"
},
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/linear
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/linear",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"zod": "3.22.3"
},
"engines": {
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/slack
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/openai",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/integration-kit": "workspace:^2.3.2"
},
"engines": {
"node": ">=18.0.0"
+16
View File
@@ -1,5 +1,21 @@
# @trigger.dev/plain
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/plain",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"@team-plain/typescript-sdk": "^2.7.0"
},
"engines": {
+1 -1
View File
@@ -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>;
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/replicate
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/replicate",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"replicate": "^0.18.1",
"zod": "3.22.3"
},
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/resend
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/resend",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"resend": "^2.0.0"
},
"engines": {
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/sendgrid
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/sendgrid",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/integration-kit": "workspace:^2.3.2"
},
"engines": {
"node": ">=16.8.0"
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/shopify
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/shopify",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/integration-kit": "workspace:^2.3.2",
"zod": "3.22.3"
},
"engines": {
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/slack
## 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
+2 -2
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/slack",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"zod": "3.22.3"
},
"engines": {
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/stripe
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/stripe",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"stripe": "^12.14.0",
"zod": "3.22.3"
},
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/supabase
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/supabase",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"supabase-management-js": "^1.0.0",
"zod": "3.22.3"
},
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/typeform
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/typeform",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/sdk": "workspace:^2.3.2",
"@typeform/api-client": "^1.8.0",
"zod": "3.22.3"
},
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/astro
## 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
+2 -2
View File
@@ -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.2",
"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.2"
},
"devDependencies": {
"astro": "^3.0.12",
+13
View File
@@ -1,5 +1,18 @@
# create-trigger
## 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
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/cli",
"version": "2.3.0",
"version": "2.3.2",
"description": "The Trigger.dev CLI",
"main": "./dist/index.js",
"types": "./dist/index.d.ts",
+8
View File
@@ -1,5 +1,13 @@
# @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
## 2.3.0
### Minor Changes
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/core-backend",
"version": "2.3.0",
"version": "2.3.2",
"description": "Core code used across `@trigger.dev/sdk` and Trigger.dev server",
"license": "MIT",
"main": "./dist/index.js",
+1
View File
@@ -1 +1,2 @@
export * from "./bloom";
export * from "./logger";
@@ -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");
}
+8
View File
@@ -1,5 +1,13 @@
# internal-platform
## 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
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/core",
"version": "2.3.0",
"version": "2.3.2",
"description": "Core code used across the Trigger.dev SDK and platform",
"license": "MIT",
"main": "./dist/index.js",
-1
View File
@@ -1,4 +1,3 @@
export * from "./logger";
export * from "./schemas";
export * from "./types";
export * from "./utils";
@@ -0,0 +1,2 @@
-- AlterTable
ALTER TABLE "JobRun" ADD COLUMN "executionFailureCount" INTEGER NOT NULL DEFAULT 0;
+3 -2
View File
@@ -811,8 +811,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)
+4
View File
@@ -1,5 +1,9 @@
# @trigger.dev/eslint-plugin
## 2.3.2
## 2.3.1
## 2.3.0
## 2.2.11
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/eslint-plugin",
"version": "2.3.0",
"version": "2.3.2",
"description": "ESLint plugin with trigger.dev best practices",
"keywords": [
"eslint",
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/express
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/express",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@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.2"
},
"dependencies": {
"debug": "^4.3.4",
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/hono
## 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
+2 -2
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/hono",
"version": "2.3.0",
"version": "2.3.2",
"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.2"
},
"devDependencies": {
"@trigger.dev/tsconfig": "workspace:*",
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/integration-kit
## 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
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/integration-kit",
"version": "2.3.0",
"version": "2.3.2",
"description": "Trigger.dev Integration Kit has helpers to make creating integrations easier",
"license": "MIT",
"main": "./dist/index.js",
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/nestjs
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/nestjs",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@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.2"
},
"dependencies": {
"@nestjs/common": "^10.2.4",
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/nextjs
## 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
+2 -2
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/nextjs",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"next": ">=12.0.0"
},
"dependencies": {
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/react
## 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
+2 -2
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/react",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"debug": "^4.3.4",
"zod": "3.22.3"
},
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/remix
## 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
+2 -2
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/remix",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@remix-run/server-runtime": ">1.19.0"
},
"dependencies": {
+13
View File
@@ -1,5 +1,18 @@
# @trigger.dev/sveltekit
## 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
+2 -2
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/sveltekit",
"version": "2.3.0",
"version": "2.3.2",
"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.2"
},
"dependencies": {
"debug": "^4.3.4"
+15
View File
@@ -1,5 +1,20 @@
# @trigger.dev/testing
## 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
+1 -1
View File
@@ -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.2",
"license": "MIT",
"main": "./dist/index.js",
"types": "./dist/index.d.ts",
+16
View File
@@ -1,5 +1,21 @@
# @trigger.dev/sdk
## 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
+3 -3
View File
@@ -1,6 +1,6 @@
{
"name": "@trigger.dev/sdk",
"version": "2.3.0",
"version": "2.3.2",
"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.2",
"@trigger.dev/core-backend": "workspace:^2.3.2",
"chalk": "^5.2.0",
"cronstrue": "^2.21.0",
"debug": "^4.3.4",
+1 -2
View File
@@ -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";
+1 -2
View File
@@ -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";
+1 -1
View File
@@ -4,11 +4,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";
+16 -26
View File
@@ -20,8 +20,6 @@ import {
IntegrationConfig,
InvokeOptions,
JobMetadata,
LogLevel,
Logger,
NormalizedResponse,
PreprocessRunBody,
PreprocessRunBodySchema,
@@ -52,8 +50,13 @@ import {
WebhookSourceRequestBodySchema,
WebhookSourceRequestHeadersSchema,
} from "@trigger.dev/core";
import { LogLevel, Logger } from "@trigger.dev/core-backend";
import { z } from "zod";
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,
@@ -71,19 +74,22 @@ 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,
GenericTriggerContext,
NotificationsEventEmitter,
Trigger,
TriggerContext,
TriggerPreprocessContext,
VerifyResult,
import { WebhookDeliveryContext, WebhookSource } from "./triggers/webhook";
import {
type EventSpecification,
type GenericTriggerContext,
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);
@@ -99,14 +105,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",
@@ -123,14 +121,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";
import { z } from "zod";
export type TriggerClientOptions = {
/** The `id` property is used to uniquely identify the client.
*/
@@ -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;
+3 -6
View File
@@ -2,25 +2,22 @@ import type {
DisplayProperty,
EventFilter,
FailedRunNotification,
Logger,
OverridableRunTaskOptions,
Prettify,
RedactString,
RegisteredOptionsDiff,
RunNotificationJobMetadata,
RunNotificationRunMetadata,
RunTaskOptions,
RuntimeEnvironmentType,
ServerTask,
SomeRequired,
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,
+30 -30
View File
@@ -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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@trigger.dev/sdk': workspace:^2.3.2
'@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.2
'@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.2
'@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.2
'@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.2
'@trigger.dev/core-backend': workspace:^2.3.2
'@trigger.dev/tsconfig': workspace:*
'@trigger.dev/tsup': workspace:*
'@types/debug': ^4.1.7