Fix pnpm lock

chore: Update version for release (#414 )
Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
2023-08-28 10:45:16 +01:00 · 2023-08-28 10:43:25 +01:00 · 2023-08-28 10:38:12 +01:00 · 2023-08-28 10:38:01 +01:00 · 2023-08-28 10:26:31 +01:00 · 2023-08-28 10:25:30 +01:00
48 changed files with 455 additions and 87 deletions
@@ -1,11 +1,24 @@
 {
  "$schema": "https://unpkg.com/@changesets/config@2.2.0/schema.json",
-  "changelog": "@changesets/cli/changelog",
+  "changelog": [
+    "@remix-run/changelog-github",
+    {
+      "repo": "triggerdotdev/trigger.dev"
+    }
+  ],
  "commit": false,
-  "fixed": [["@trigger.dev/*"]],
+  "fixed": [
+    [
+      "@trigger.dev/*"
+    ]
+  ],
  "linked": [],
  "access": "public",
  "baseBranch": "main",
  "updateInternalDependencies": "patch",
-  "ignore": ["webapp", "emails", "@trigger.dev/database"]
-}
+  "ignore": [
+    "webapp",
+    "emails",
+    "@trigger.dev/database"
+  ]
+}
@@ -71,7 +71,7 @@ jobs:
          commit: "chore: Update version for release"
          title: "chore: Update version for release"
          publish: pnpm run changeset:release
-          createGithubReleases: false
+          createGithubReleases: true
        env:
          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
@@ -477,7 +477,9 @@ export class PerformRunExecutionV2Service {
  }
 }

-function prepareTasksForRun(tasks: FoundTask[]): CachedTask[] {
+function prepareTasksForRun(possibleTasks: FoundTask[]): CachedTask[] {
+  const tasks = possibleTasks.filter((task) => task.status === "COMPLETED");
+
  // We need to limit the cached tasks to not be too large >3.5MB when serialized
  const TOTAL_CACHED_TASK_BYTE_LIMIT = 3500000;

@@ -121,6 +121,7 @@ Available triggers are listed below:
 | `onPersonCreated`               | `account.person.created`                                                                                                                                                                                                                                            | Triggered on person created events                | `onPerson`               |
 | `onPersonUpdated`               | `account.person.updated`                                                                                                                                                                                                                                            | Triggered on person updated events                | `onPerson`               |
 | `onPersonDeleted`               | `account.person.deleted`                                                                                                                                                                                                                                            | Triggered on person deleted events                | `onPerson`               |
+| `onAccountUpdated`              | `account.updated`                                                                                                                                                                                                                                                   | Triggered on account updated events               | N/A                      |

 If there are any triggers missing that you'd like to see added, please [open a new GitHub Issue](https://github.com/triggerdotdev/trigger.dev/issues/new)

@@ -1,5 +1,6 @@
 import { createExpressServer } from "@trigger.dev/express";
 import { TriggerClient, eventTrigger } from "@trigger.dev/sdk";
+import { z } from "zod";

 export const client = new TriggerClient({
  id: "job-catalog",
@@ -56,4 +57,45 @@ client.defineJob({
  },
 });

+client.defineJob({
+  id: "example-job",
+  name: "Example Job: a joke with a delay",
+  version: "0.0.2",
+  trigger: eventTrigger({
+    name: "shayan.event",
+    schema: z.object({
+      userId: z.string(),
+      delay: z.number(),
+    }),
+  }),
+  run: async (payload, io, ctx) => {
+    await io.wait("sleeping", payload.delay);
+
+    await io.runTask("init", { name: "init" }, async () => {
+      console.log("init function ran", payload.userId);
+    });
+
+    await io.runTask("failable", { name: "task-1", retry: { limit: 3 } }, async (task) => {
+      if (task.attempts > 2) {
+        console.log("task succeeded");
+        return {
+          ok: true,
+        };
+      }
+      console.log("task failed");
+      throw new Error(`Task failed on ${task.attempts} attempt(s)`);
+    });
+
+    await io.runTask(
+      "log",
+      {
+        name: "log",
+      },
+      async () => {
+        console.log("hello from the job", payload.userId);
+      }
+    );
+  },
+});
+
 createExpressServer(client);
@@ -1,5 +1,13 @@
 # @trigger.dev/github

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/github",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "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/sdk": "workspace:^2.0.12",
-    "@trigger.dev/integration-kit": "workspace:^2.0.12",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13",
    "octokit": "^2.0.14",
    "zod": "3.21.4"
  },
@@ -1,5 +1,13 @@
 # @trigger.dev/slack

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/openai",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "The official OpenAI integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
  },
  "dependencies": {
    "openai": "^4.2.0",
-    "@trigger.dev/sdk": "workspace:^2.0.12",
-    "@trigger.dev/integration-kit": "workspace:^2.0.12"
+    "@trigger.dev/sdk": "workspace:^2.0.13",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13"
  },
  "engines": {
    "node": ">=16.8.0"
@@ -1,5 +1,13 @@
 # @trigger.dev/plain

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/plain",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "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.0.12",
-    "@trigger.dev/sdk": "workspace:^2.0.12",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "@team-plain/typescript-sdk": "^2.7.0"
  },
  "engines": {
@@ -1,5 +1,13 @@
 # @trigger.dev/resend

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/resend",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "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.0.12",
-    "@trigger.dev/sdk": "workspace:^2.0.12",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "resend": "^0.9.1"
  },
  "engines": {
@@ -1,5 +1,13 @@
 # @trigger.dev/sendgrid

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/sendgrid",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "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.0.12",
-    "@trigger.dev/integration-kit": "workspace:^2.0.12"
+    "@trigger.dev/sdk": "workspace:^2.0.13",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13"
  },
  "engines": {
    "node": ">=16.8.0"
@@ -1,5 +1,12 @@
 # @trigger.dev/slack

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/slack",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "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.0.12",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "zod": "3.21.4"
  },
  "engines": {
@@ -1,5 +1,13 @@
 # @trigger.dev/stripe

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/stripe",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "Trigger.dev integration for stripe",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
    "typecheck": "tsc --noEmit"
  },
  "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.0.12",
-    "@trigger.dev/sdk": "workspace:^2.0.12",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "stripe": "^12.14.0",
    "zod": "3.21.4"
  },
@@ -1,5 +1,13 @@
 # @trigger.dev/supabase

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/supabase",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "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.0.12",
-    "@trigger.dev/sdk": "workspace:^2.0.12",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "supabase-management-js": "^0.1.4",
    "zod": "3.21.4"
  },
@@ -1,5 +1,13 @@
 # @trigger.dev/typeform

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+  - `@trigger.dev/integration-kit@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/typeform",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "The official Typeform integration for Trigger.dev",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
  },
  "dependencies": {
    "@typeform/api-client": "^1.8.0",
-    "@trigger.dev/sdk": "workspace:^2.0.12",
-    "@trigger.dev/integration-kit": "workspace:^2.0.12",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
+    "@trigger.dev/integration-kit": "workspace:^2.0.13",
    "zod": "3.21.4"
  },
  "engines": {
@@ -64,6 +64,7 @@
  "packageManager": "pnpm@7.18.1",
  "dependencies": {
    "@changesets/cli": "^2.26.0",
+    "@remix-run/changelog-github": "^0.0.5",
    "node-fetch": "2.6.x"
  }
 }
@@ -1,5 +1,12 @@
 # @trigger.dev/astro

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,12 +1,12 @@
 {
  "name": "@trigger.dev/astro",
  "description": "An Astro-native integration for Trigger.dev background jobs platform",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "type": "module",
  "main": "main.js",
  "scripts": {},
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.0.12",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "astro": "^2.10.7"
  },
  "engines": {
@@ -1,5 +1,13 @@
 # create-trigger

+## 2.0.13
+
+### Patch Changes
+
+- provided a fix to the CLI dev command tunnel not working if you are already running ngrok ([#407](https://github.com/triggerdotdev/trigger.dev/pull/407))
+- fix: init will no longer fail when outside of a git repo ([`3028b6ad`](https://github.com/triggerdotdev/trigger.dev/commit/3028b6ad9d693d2f1662c4338d44ac9d3bf0da3a))
+- feat: Checks for outdated packages when running the dev command with instructions on how to update ([#412](https://github.com/triggerdotdev/trigger.dev/pull/412))
+
 ## 2.0.12

 ## 2.0.11
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/cli",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "The Trigger.dev CLI",
  "main": "./dist/index.js",
  "types": "./dist/index.d.ts",
@@ -12,6 +12,8 @@ import { getTriggerApiDetails } from "../utils/getTriggerApiDetails";
 import { logger } from "../utils/logger";
 import { resolvePath } from "../utils/parseNameAndPath";
 import { TriggerApi } from "../utils/triggerApi";
+import { run as ncuRun } from 'npm-check-updates'
+import chalk from "chalk";

 const asyncExecFile = util.promisify(childProcess.execFile);

@@ -45,6 +47,7 @@ export async function devCommand(path: string, anyOptions: any) {
  const options = result.data;

  const resolvedPath = resolvePath(path);
+  await checkForOutdatedPackages(resolvedPath)

  // Read from package.json to get the endpointId
  const endpointId = await getEndpointIdFromPackageJson(resolvedPath, options);
@@ -205,6 +208,36 @@ export async function devCommand(path: string, anyOptions: any) {
  throttle(refresh, throttleTimeMs);
 }

+export async function checkForOutdatedPackages(path: string) {
+
+  const updates = await ncuRun({
+    packageFile: `${path}/package.json`,
+    filter: "/trigger.dev\/.+$/",
+    upgrade: false,
+  }) as {
+    [key: string]: string;
+  }
+
+  if (typeof updates === 'undefined' || Object.keys(updates).length === 0) {
+    return;
+  }
+
+  const packageFile = await fs.readFile(`${path}/package.json`);
+  const data = JSON.parse(Buffer.from(packageFile).toString('utf8'));
+  const dependencies = data.dependencies;
+  console.log(
+    chalk.bgYellow('Updates available for trigger.dev packages')
+  );
+  console.log(
+    chalk.bgBlue('Run npx @trigger.dev/cli@latest update')
+  );
+
+  for (let dep in updates) {
+    console.log(`${dep}  ${dependencies[dep]}  →  ${updates[dep]}`);
+  }
+
+}
+
 export async function getEndpointIdFromPackageJson(path: string, options: DevCommandOptions) {
  if (options.clientId) {
    return options.clientId;
@@ -258,6 +291,16 @@ async function createTunnel(port: number, spinner: Ora) {
        return;
      }
    }
+    if (
+      typeof error.message === "string" &&
+      error.message.includes("connect ECONNREFUSED 127.0.0.1:4041")
+    ) {
+      spinner.fail(
+        `Ngrok failed to create a tunnel for port ${port} because ngrok is already running`
+      );
+      return;
+    }
+    spinner.fail(`Ngrok failed to create a tunnel for port ${port}.\n${error.message}`);
    return;
  }
 }
@@ -253,9 +253,19 @@ const resolveOptionsWithPrompts = async (
 // Detects if there are any uncommitted git changes at path
 async function detectGitChanges(path: string): Promise<boolean> {
  const git = simpleGit(path);
-  const status = await git.status();

-  return status.files.length > 0;
+  try {
+    const isRepo = await git.checkIsRepo();
+
+    if (isRepo) {
+      // Check if there are uncommitted changes
+      const status = await git.status();
+      return status.files.length > 0;
+    }
+    return false;
+  } catch (error) {
+    return false;
+  }
 }

 async function detectTypescriptProject(path: string): Promise<boolean> {
@@ -1,5 +1,7 @@
 # internal-platform

+## 2.0.13
+
 ## 2.0.12

 ## 2.0.11
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/core",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "Core code used across the Trigger.dev SDK and platform",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -1,5 +1,11 @@
 # @trigger.dev/eslint-plugin

+## 2.0.13
+
+### Patch Changes
+
+- Fixes #391, now handling jobs when using new Job instead of client.defineJob ([`3028b6ad`](https://github.com/triggerdotdev/trigger.dev/commit/3028b6ad9d693d2f1662c4338d44ac9d3bf0da3a))
+
 ## 2.0.12

 ## 2.0.11
@@ -49,10 +49,7 @@ module.exports = {
      return property.name;
    }

-    const groupExpressionsByTask = (ExpressionStatements, map = new Map()) => ExpressionStatements.reduce((acc, { expression }) => {
-      const taskName = getTaskName(expression);
-      const taskKey = getKey(expression);
-
+    const groupByTaskKeyAndName = (acc, { taskKey, taskName }) => {
      if (acc.has(taskName)) {
        acc.get(taskName).push(taskKey);
      } else {
@@ -60,6 +57,13 @@ module.exports = {
      }

      return acc;
+    }
+
+    const groupExpressionsByTask = (ExpressionStatements, map = new Map()) => ExpressionStatements.reduce((acc, { expression }) => {
+      const taskName = getTaskName(expression);
+      const taskKey = getKey(expression);
+
+      return groupByTaskKeyAndName(acc, { taskKey, taskName });
    }, map);

    const groupVariableDeclarationsByTask = VariableDeclarations => VariableDeclarations.reduce((acc, { declarations }) => {
@@ -70,30 +74,46 @@ module.exports = {
        
        const taskKey = getKey(declaration.init);

-        if (acc.has(taskName)) {
-          acc.get(taskName).push(taskKey);
-        } else {
-          acc.set(taskName, [taskKey]);
-        }
+        groupByTaskKeyAndName(acc, { taskKey, taskName });
      });

      return acc;
    }, new Map());

+    const getInnerIfStatementBodies = (body) => body
+      .filter((arg) => arg.type === 'IfStatement')
+      .reduce((acc, arg) => {
+        const consequent = arg.consequent.body;
+
+        const AlternateBodies = getInnerIfStatementBodies(consequent);
+
+        const body = consequent.filter((arg) => arg.type !== 'IfStatement');
+
+        return acc.concat(body).concat(AlternateBodies);
+      }, [])
+
+    const getNodeBody = (node) => {
+      const body = node.value.body.body;
+
+      return body
+        .filter((arg) => arg.type !== 'IfStatement')
+        .concat(getInnerIfStatementBodies(body));
+    }
+
    return {
-      "CallExpression[callee.property.name='defineJob'] ObjectExpression BlockStatement": (node) => {
-        const VariableDeclarations = node.body.filter((arg) => arg.type === 'VariableDeclaration');
+      "Property[key.name='run']": (node) => {
+        const body = getNodeBody(node);

+        const VariableDeclarations = body.filter((arg) => arg.type === 'VariableDeclaration');
+  
        const grouped = groupVariableDeclarationsByTask(VariableDeclarations);
-
-        const ExpressionStatements = node.body.filter((arg) => arg.type === 'ExpressionStatement');
-
+  
+        const ExpressionStatements = body.filter((arg) => arg.type === 'ExpressionStatement');
+  
        // it'll be a map of taskName => [key1, key2, ...]
        const groupedByTask = groupExpressionsByTask(ExpressionStatements, grouped);
-
        groupedByTask.forEach((keys) => {
          const duplicated = keys.find((key, index) => keys.indexOf(key) !== index);
-
          if (duplicated) {
            context.report({
              node,
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/eslint-plugin",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "ESLint plugin with trigger.dev best practices",
  "keywords": [
    "eslint",
@@ -240,6 +240,86 @@ ruleTester.run("no-duplicated-task-keys", rule, {
        { message: "Task key 'Get Tag' is duplicated" },
        { message: "Task key 'Tag ' is duplicated" },
      ]
+    },
+    {
+      code: `import { Job, eventTrigger } from "@trigger.dev/sdk";
+      import { client } from "@/trigger";
+      
+      // your first job
+      new Job(client, {
+        id: "example-job",
+        name: "Example Job",
+        version: "0.0.1",
+        trigger: eventTrigger({
+          name: "example.event",
+        }),
+        run: async (payload, io, ctx) => {
+          await io.runTask("example.task", { name: "Task 1" }, async () => {});
+          await io.runTask("example.task", { name: "Task 2" }, async () => {});
+        },
+      });`,
+      errors: [
+        { message: "Task key 'example.task' is duplicated" },
+      ]
+    },
+    {
+      code: `import { Job, eventTrigger } from "@trigger.dev/sdk";
+      import { client } from "@/trigger";
+      
+      // your first job
+      new Job(client, {
+        id: "example-job",
+        name: "Example Job",
+        version: "0.0.1",
+        trigger: eventTrigger({
+          name: "example.event",
+        }),
+        run: async (payload, io, ctx) => {
+          await io.runTask("example.task", { name: "Task 1" }, async () => {});
+      
+          await io.anotherTask("different task", { name: "Task 1" }, async () => {});
+      
+          if (true) {
+            await io.runTask("example.task", { name: "Task 2" }, async () => {});
+      
+            if (true) {
+              await io.runTask("example.task", { name: "Task 3" }, async () => {});
+              await io.anotherTask("different task", { name: "Task 1" }, async () => {});
+            }
+          }
+        },
+      });`,
+      errors: [
+        { message: "Task key 'example.task' is duplicated" },
+        { message: "Task key 'different task' is duplicated" },
+      ]
+    },
+    {
+      code: `import { Job, eventTrigger } from "@trigger.dev/sdk";
+      import { client } from "@/trigger";
+      
+      // your first job
+      new Job(client, {
+        id: "example-job",
+        name: "Example Job",
+        version: "0.0.1",
+        trigger: eventTrigger({
+          name: "example.event",
+        }),
+        run: async (payload, io, ctx) => {
+          if (true) {
+            await io.runTask("example.task", { name: "Task 1" }, async () => {});
+      
+            if (true) {
+              await io.runTask("example.task", { name: "Task 2" }, async () => {});
+              await io.anotherTask("different task", { name: "Task 1" }, async () => {});
+            }
+          }
+        },
+      });`,
+      errors: [
+        { message: "Task key 'example.task' is duplicated" },
+      ]
    }
  ]
 });
@@ -1,5 +1,12 @@
 # @trigger.dev/express

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/express",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "Official Express adapter for Trigger.dev",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -19,7 +19,7 @@
    "./package.json": "./package.json"
  },
  "devDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.0.12",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "@trigger.dev/tsconfig": "workspace:*",
    "@types/debug": "^4.1.7",
    "@types/express": "^4.17.13",
@@ -33,7 +33,7 @@
    "build:tsup": "tsup"
  },
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.0.12"
+    "@trigger.dev/sdk": "workspace:^2.0.13"
  },
  "dependencies": {
    "@remix-run/web-fetch": "^4.3.5",
@@ -1,5 +1,7 @@
 # @trigger.dev/integration-kit

+## 2.0.13
+
 ## 2.0.12

 ## 2.0.11
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/integration-kit",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "Trigger.dev Integration Kit has helpers to make creating integrations easier",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -1,5 +1,12 @@
 # @trigger.dev/nextjs

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/sdk@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/nextjs",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "Trigger.dev Next.js integration",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -33,7 +33,7 @@
    "build:tsup": "tsup"
  },
  "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.0.12",
+    "@trigger.dev/sdk": "workspace:^2.0.13",
    "next": ">=12.0.0 <14.0.0"
  },
  "dependencies": {
@@ -1,5 +1,12 @@
 # @trigger.dev/react

+## 2.0.13
+
+### Patch Changes
+
+- Updated dependencies:
+  - `@trigger.dev/core@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/react",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "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.0.12",
+    "@trigger.dev/core": "workspace:^2.0.13",
    "debug": "^4.3.4",
    "zod": "3.21.4"
  },
@@ -1,5 +1,13 @@
 # @trigger.dev/sdk

+## 2.0.13
+
+### Patch Changes
+
+- Only use cached tasks if they are completed, otherwise retrying tasks will be considered successful ([`916a3536`](https://github.com/triggerdotdev/trigger.dev/commit/916a353660e251946d76bdf565c26b7801d3beb8))
+- Updated dependencies:
+  - `@trigger.dev/core@2.0.13`
+
 ## 2.0.12

 ### Patch Changes
@@ -1,6 +1,6 @@
 {
  "name": "@trigger.dev/sdk",
-  "version": "2.0.12",
+  "version": "2.0.13",
  "description": "trigger.dev Node.JS SDK",
  "license": "MIT",
  "main": "./dist/index.js",
@@ -25,7 +25,7 @@
    "typecheck": "tsc --noEmit"
  },
  "dependencies": {
-    "@trigger.dev/core": "workspace:^2.0.12",
+    "@trigger.dev/core": "workspace:^2.0.13",
    "chalk": "^5.2.0",
    "cronstrue": "^2.21.0",
    "debug": "^4.3.4",
@@ -504,8 +504,8 @@ export class IO {

    const cachedTask = this._cachedTasks.get(idempotencyKey);

-    if (cachedTask) {
-      this._logger.debug("Using cached task", {
+    if (cachedTask && cachedTask.status === "COMPLETED") {
+      this._logger.debug("Using completed cached task", {
        idempotencyKey,
        cachedTask,
      });
@@ -7,6 +7,7 @@ importers:
      '@changesets/cli': ^2.26.0
      '@manypkg/cli': ^0.19.2
      '@playwright/test': ^1.36.2
+      '@remix-run/changelog-github': ^0.0.5
      '@tailwindcss/forms': ^0.5.3
      '@tailwindcss/typography': ^0.5.8
      '@trigger.dev/cli': workspace:*
@@ -25,6 +26,7 @@ importers:
      vitest: ^0.28.4
    dependencies:
      '@changesets/cli': 2.26.0
+      '@remix-run/changelog-github': 0.0.5
      node-fetch: 2.6.7
    devDependencies:
      '@manypkg/cli': 0.19.2
@@ -614,8 +616,8 @@ importers:
      '@octokit/types': ^9.2.3
      '@octokit/webhooks': ^10.4.0
      '@octokit/webhooks-types': ^6.10.0
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/node': '18'
      octokit: ^2.0.14
@@ -640,8 +642,8 @@ importers:

  integrations/openai:
    specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/node': '18'
      openai: ^4.2.0
@@ -660,8 +662,8 @@ importers:
  integrations/plain:
    specifiers:
      '@team-plain/typescript-sdk': ^2.7.0
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/node': '18'
      rimraf: ^3.0.2
@@ -678,8 +680,8 @@ importers:

  integrations/resend:
    specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/node': '18'
      resend: ^0.9.1
@@ -698,8 +700,8 @@ importers:
  integrations/sendgrid:
    specifiers:
      '@sendgrid/mail': ^7.7.0
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@types/node': 16.x
      rimraf: ^3.0.2
      tsup: 7.1.x
@@ -717,7 +719,7 @@ importers:
  integrations/slack:
    specifiers:
      '@slack/web-api': ^6.8.1
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/node': '18'
      rimraf: ^3.0.2
@@ -735,8 +737,8 @@ importers:

  integrations/stripe:
    specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@types/node': 16.x
      rimraf: ^3.0.2
      stripe: ^12.14.0
@@ -759,8 +761,8 @@ importers:
  integrations/supabase:
    specifiers:
      '@supabase/supabase-js': ^2.26.0
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@types/node': 18.x
      rimraf: ^3.0.2
      supabase-management-js: ^0.1.4
@@ -781,8 +783,8 @@ importers:

  integrations/typeform:
    specifiers:
-      '@trigger.dev/integration-kit': workspace:^2.0.12
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/integration-kit': workspace:^2.0.13
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@typeform/api-client': ^1.8.0
      '@types/node': 16.x
      rimraf: ^3.0.2
@@ -987,7 +989,7 @@ importers:
  packages/express:
    specifiers:
      '@remix-run/web-fetch': ^4.3.5
-      '@trigger.dev/sdk': workspace:^2.0.12
+      '@trigger.dev/sdk': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/debug': ^4.1.7
      '@types/express': ^4.17.13
@@ -1056,7 +1058,7 @@ importers:
  packages/react:
    specifiers:
      '@tanstack/react-query': 5.0.0-beta.2
-      '@trigger.dev/core': workspace:^2.0.12
+      '@trigger.dev/core': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/debug': ^4.1.7
      '@types/react': 18.2.17
@@ -1086,7 +1088,7 @@ importers:

  packages/trigger-sdk:
    specifiers:
-      '@trigger.dev/core': workspace:^2.0.12
+      '@trigger.dev/core': workspace:^2.0.13
      '@trigger.dev/tsconfig': workspace:*
      '@types/debug': ^4.1.7
      '@types/node': '18'
@@ -3778,6 +3780,15 @@ packages:
      semver: 5.7.1
    dev: false

+  /@changesets/get-github-info/0.5.2:
+    resolution: {integrity: sha512-JppheLu7S114aEs157fOZDjFqUDpm7eHdq5E8SSR0gUBTEK0cNSHsrSR5a66xs0z3RWuo46QvA3vawp8BxDHvg==}
+    dependencies:
+      dataloader: 1.4.0
+      node-fetch: 2.6.12
+    transitivePeerDependencies:
+      - encoding
+    dev: false
+
  /@changesets/get-release-plan/3.0.16:
    resolution: {integrity: sha512-OpP9QILpBp1bY2YNIKFzwigKh7Qe9KizRsZomzLe6pK8IUo8onkAAVUD8+JRKSr8R7d4+JRuQrfSSNlEwKyPYg==}
    dependencies:
@@ -8712,6 +8723,17 @@ packages:
      react: 18.2.0
    dev: false

+  /@remix-run/changelog-github/0.0.5:
+    resolution: {integrity: sha512-43tqwUqWqirbv6D9uzo55ASPsCJ61Ein1k/M8qn+Qpros0MmbmuzjLVPmtaxfxfe2ANX0LefLvCD0pAgr1tp4g==}
+    dependencies:
+      '@changesets/errors': 0.1.4
+      '@changesets/get-github-info': 0.5.2
+      '@changesets/types': 5.2.1
+      dotenv: 8.6.0
+    transitivePeerDependencies:
+      - encoding
+    dev: false
+
  /@remix-run/dev/1.19.2-pre.0_36n2i74sizt32vwpdxc4husnkq:
    resolution: {integrity: sha512-8s7g8jLueKcIr5Gb7qvZRJVzfHx2KqyApGYW55LrQ63kNwZwuKHglYSMoaQGB4xUhX2cfmzW7pIcunfbh3SNyA==}
    engines: {node: '>=14.0.0'}
@@ -14268,6 +14290,10 @@ packages:
    engines: {node: '>= 14'}
    dev: true

+  /dataloader/1.4.0:
+    resolution: {integrity: sha512-68s5jYdlvasItOJnCuI2Q9s4q98g0pCyL3HrcKJu8KNugUl8ahgmZYg38ysLTgQjjXX3H8CJLkAvWrclWfcalw==}
+    dev: false
+
  /date-fns/2.30.0:
    resolution: {integrity: sha512-fnULvOpxnC5/Vg3NCiWelDsLiUc9bRwAPs/+LfTLNvetFCtCTN+yQz15C/fs4AwX1R9K5GLtLfn8QW+dWisaAw==}
    engines: {node: '>=0.11'}
@@ -14760,6 +14786,11 @@ packages:
    resolution: {integrity: sha512-IPzF4w4/Rd94bA9imS68tZBaYyBWSCE47V1RGuMrB94iyTOIEwRmVL2x/4An+6mETpLrKJ5hQkB8W4kFAadeIQ==}
    engines: {node: '>=12'}

+  /dotenv/8.6.0:
+    resolution: {integrity: sha512-IrPdXQsk2BbzvCBGBOTmmSH5SodmqZNt4ERAZDmW4CT+tL8VtvinqywuANaFu4bOMWki16nqf0e4oC0QIaDr/g==}
+    engines: {node: '>=10'}
+    dev: false
+
  /duplexer2/0.1.4:
    resolution: {integrity: sha512-asLFVfWWtJ90ZyOUHMqk7/S2w2guQKxUI2itj3d92ADHhxUSbCMGi1f1cBcJ7xM1To+pE/Khbwo1yuNbMEPKeA==}
    dependencies:
Author	SHA1	Message	Date
Eric Allam	81f2d5e4ec	Fix pnpm lock	2023-08-28 10:45:16 +01:00
github-actions[bot]	f249d8defa	chore: Update version for release (#414 ) Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>	2023-08-28 10:43:25 +01:00
Eric Allam	09aef5cda7	Merge branch 'main' of https://github.com/triggerdotdev/trigger.dev	2023-08-28 10:38:12 +01:00
Eric Allam	3028b6ad9d	Try to automatically create github releases when packages are updated	2023-08-28 10:38:01 +01:00
Wesley	060b650845	fix/TRI 1149/cover all duplicated cases (#398 ) * feat: select node by property key name * feat: get `IfStatement`s recursively * refactor: make `getNodeBody` more readable * refactor: enshorter rule code * refactor: remove additional spaces * Create lovely-teachers-taste.md --------- Co-authored-by: Eric Allam <eallam@icloud.com>	2023-08-28 10:26:31 +01:00
Chigala	6186a14398	fix: CLI init doesn't work outside of a GIT repo (#405 )	2023-08-28 10:25:30 +01:00
Eric Allam	916a353660	bugfix: retrying tasks no longer incorrectly complete successfully	2023-08-28 10:16:47 +01:00
neo773	699878a5b1	feat: Add update checker for CLI (#412 ) * feat: Add update checker for CLI * Create soft-hounds-clap.md --------- Co-authored-by: Eric Allam <eallam@icloud.com>	2023-08-28 09:36:53 +01:00
Chigala	d2c9b64212	fix: CLI dev command doesn't work if you're already running ngrok (#407 ) * fix: CLI dev command doesn't work if you're already running ngrok * added changeset	2023-08-28 09:26:26 +01:00
Eric Allam	3102deccfb	Add onAccountUpdated to the list of stripe triggers in the docs	2023-08-27 21:54:22 +01:00