Latest lockfile

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

.github/workflows/publish-docker.yml

@@ -3,7 +3,12 @@ on:
   workflow_call:
 jobs:
   publish:
-    runs-on: buildjet-4vcpu-ubuntu-2204
+    strategy:
+      fail-fast: true # when a job fails, all remaining ones will be cancelled
+      matrix:
+        runs-on: [buildjet-4vcpu-ubuntu-2204, buildjet-4vcpu-ubuntu-2204-arm]
+    name: ${{matrix.runs-on}}
+    runs-on: ${{matrix.runs-on}}
     outputs:
       version: ${{ steps.get_version.outputs.version }}
       short_sha: ${{ steps.get_commit.outputs.sha_short }}
@@ -36,6 +41,9 @@ jobs:
             echo "Invalid reference: ${GITHUB_REF}"
             exit 1
           fi
+          if [[ ${{matrix.runs-on}} == *-arm ]]; then
+            IMAGE_TAG="${IMAGE_TAG}-arm"
+          fi
           echo "::set-output name=version::${IMAGE_TAG}"
       - name: 🔢 Get the commit hash
         id: get_commit
@@ -65,8 +73,12 @@ jobs:
       - name: 🐙 Push 'latest' to GitHub Container Registry
         if: startsWith(github.ref, 'refs/tags/v.docker')
         run: |
-          docker tag release_build_image $REGISTRY/$REPOSITORY:latest
-          docker push $REGISTRY/$REPOSITORY:latest
+          LATEST=latest
+          if [[ ${{matrix.runs-on}} == *-arm ]]; then
+            LATEST="${LATEST}-arm"
+          fi
+          docker tag release_build_image $REGISTRY/$REPOSITORY:$LATEST
+          docker push $REGISTRY/$REPOSITORY:$LATEST
         env:
           REGISTRY: ghcr.io/triggerdotdev
           REPOSITORY: trigger.dev

apps/webapp/app/components/environments/EnvironmentLabel.tsx

@@ -5,9 +5,11 @@ type Environment = Pick<RuntimeEnvironment, "type">;
 
 export function EnvironmentLabel({
   environment,
+  userName,
   className,
 }: {
   environment: Environment;
+  userName?: string;
   className?: string;
 }) {
   return (
@@ -18,19 +20,19 @@ export function EnvironmentLabel({
         className
       )}
     >
-      {environmentTitle(environment)}
+      {environmentTitle(environment, userName)}
     </span>
   );
 }
 
-export function environmentTitle(environment: Environment) {
+export function environmentTitle(environment: Environment, username?: string) {
   switch (environment.type) {
     case "PRODUCTION":
       return "Prod";
     case "STAGING":
       return "Staging";
     case "DEVELOPMENT":
-      return "Dev";
+      return username ? `Dev: ${username}` : "Dev";
     case "PREVIEW":
       return "Preview";
   }

apps/webapp/app/components/integrations/CustomHelp.tsx

@@ -3,37 +3,10 @@ import { CodeExample } from "~/routes/resources.codeexample";
 import { Api } from "~/services/externalApis/apis.server";
 import { cn } from "~/utils/cn";
 import { Feedback } from "../Feedback";
-import { Header1, Header2 } from "../primitives/Headers";
+import { Header1, Header2, Header3 } from "../primitives/Headers";
 import { Paragraph } from "../primitives/Paragraph";
 import { TextLink } from "../primitives/TextLink";
 
-const fallbackExamples = [
-  {
-    title: "Post to Slack when meetings are booked or cancelled.",
-    slug: "cal-slack-meeting-alert",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/cal-http-endpoint.ts",
-  },
-  {
-    title: "Translate some text with DeepL.",
-    slug: "translate-text-with-deepl",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/deepl.ts",
-  },
-  {
-    title: "Create a Discord bot and send a message to a channel.",
-    slug: "discord-bot-send-message",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/discord.ts",
-  },
-  {
-    title: "Retrieve a Notion page by ID.",
-    slug: "retrieve-notion-page",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/notion.ts",
-  },
-];
-
 export function CustomHelp({ api }: { api: Api }) {
   const [selectedExample, setSelectedExample] = useState(0);
 
@@ -43,7 +16,7 @@ export function CustomHelp({ api }: { api: Api }) {
 
   return (
     <div className="mt-4">
-      <Header1 className="mb-2">Using an API with an SDK or requests</Header1>
+      <Header1 className="mb-2">Using {api.name} with an SDK or requests</Header1>
       <Paragraph spacing>
         You can use Trigger.dev with any existing Node SDK or even just using fetch. You can
         subscribe to any API with{" "}
@@ -87,9 +60,13 @@ export function CustomHelp({ api }: { api: Api }) {
         </>
       ) : (
         <>
-          <Header2 className="mb-2">Example code using fetch / an existing SDK</Header2>
+          <Header2 className="mb-2">Getting started with {api.name}</Header2>
+          <Paragraph spacing className="mb-4">
+            We recommend searching for the official {api.name} Node SDK. If they have one, you can
+            install it and then use their API documentation to get started and create tasks. If they
+            don't, there are often third party SDKs you can use instead.
+          </Paragraph>
           <Paragraph spacing className="mb-4">
-            You can use one of our examples below as a starting point / reference for your projects.
             Please{" "}
             <Feedback
               button={
@@ -99,24 +76,9 @@ export function CustomHelp({ api }: { api: Api }) {
               }
               defaultValue="help"
             />{" "}
-            if you're having any issues.
+            if you're having any issues connecting to {api.name}, we'll help you get set up as
+            quickly as possible.
           </Paragraph>
-
-          <div className=" flex w-full flex-row gap-4 overflow-x-scroll	scrollbar-thin scrollbar-track-transparent scrollbar-thumb-slate-700 sm:h-full">
-            {fallbackExamples.map((example, index) => (
-              <button
-                onClick={() => changeCodeExample(index)}
-                key={example.codeUrl}
-                className={cn(
-                  "w-64 min-w-[16rem] p-2 transition-colors duration-300 sm:w-full sm:rounded",
-                  "border-px focus:border-px cursor-pointer border border-slate-900 bg-slate-900 text-slate-300 transition duration-300 hover:bg-slate-800 focus:border focus:border-indigo-600"
-                )}
-              >
-                {example.title}
-              </button>
-            ))}
-          </div>
-          <CodeExample example={fallbackExamples[selectedExample]} />
         </>
       )}
     </div>

apps/webapp/app/components/run/RunOverview.tsx

@@ -10,7 +10,7 @@ import {
   useNavigate,
   useNavigation,
 } from "@remix-run/react";
-import { RuntimeEnvironmentType } from "@trigger.dev/database";
+import { RuntimeEnvironmentType, User } from "@trigger.dev/database";
 import { useMemo } from "react";
 import { usePathName } from "~/hooks/usePathName";
 import type { RunBasicStatus } from "~/models/jobRun.server";
@@ -66,11 +66,12 @@ type RunOverviewProps = {
     run: string;
     runsPath: string;
   };
+  currentUser: User;
 };
 
 const taskPattern = /\/tasks\/(.*)/;
 
-export function RunOverview({ run, trigger, showRerun, paths }: RunOverviewProps) {
+export function RunOverview({ run, trigger, showRerun, paths, currentUser }: RunOverviewProps) {
   const navigate = useNavigate();
   const pathName = usePathName();
 
@@ -90,6 +91,9 @@ export function RunOverview({ run, trigger, showRerun, paths }: RunOverviewProps
     }
   }, [pathName]);
 
+  const usernameForEnv =
+    currentUser.id !== run.environment.userId ? run.environment.userName : undefined;
+
   return (
     <PageContainer>
       <PageHeader>
@@ -136,7 +140,7 @@ export function RunOverview({ run, trigger, showRerun, paths }: RunOverviewProps
             <PageInfoProperty icon={"property"} label={"Version"} value={`v${run.version}`} />
             <PageInfoProperty
               label={"Env"}
-              value={<EnvironmentLabel environment={run.environment} />}
+              value={<EnvironmentLabel environment={run.environment} userName={usernameForEnv} />}
             />
             <PageInfoProperty
               icon={"clock"}

apps/webapp/app/components/runs/RunsTable.tsx

@@ -1,6 +1,6 @@
 import { StopIcon } from "@heroicons/react/24/outline";
 import { CheckIcon } from "@heroicons/react/24/solid";
-import { JobRunStatus, RuntimeEnvironmentType } from "@trigger.dev/database";
+import { JobRunStatus, RuntimeEnvironmentType, User } from "@trigger.dev/database";
 import { formatDuration, formatDurationMilliseconds } from "~/utils";
 import { EnvironmentLabel } from "../environments/EnvironmentLabel";
 import { DateTime } from "../primitives/DateTime";
@@ -23,6 +23,8 @@ type RunTableItem = {
   number: number | null;
   environment: {
     type: RuntimeEnvironmentType;
+    userId?: string;
+    userName?: string;
   };
   job: { title: string; slug: string };
   status: JobRunStatus;
@@ -41,6 +43,7 @@ type RunsTableProps = {
   runs: RunTableItem[];
   isLoading?: boolean;
   runsParentPath: string;
+  currentUser: User;
 };
 
 export function RunsTable({
@@ -50,6 +53,7 @@ export function RunsTable({
   isLoading = false,
   showJob = false,
   runsParentPath,
+  currentUser,
 }: RunsTableProps) {
   return (
     <Table>
@@ -84,6 +88,8 @@ export function RunsTable({
             const path = showJob
               ? `${runsParentPath}/jobs/${run.job.slug}/runs/${run.id}/trigger`
               : `${runsParentPath}/${run.id}/trigger`;
+            const usernameForEnv =
+              currentUser.id !== run.environment.userId ? run.environment.userName : undefined;
             return (
               <TableRow key={run.id}>
                 <TableCell to={path}>
@@ -91,7 +97,7 @@ export function RunsTable({
                 </TableCell>
                 {showJob && <TableCell to={path}>{run.job.slug}</TableCell>}
                 <TableCell to={path}>
-                  <EnvironmentLabel environment={run.environment} />
+                  <EnvironmentLabel environment={run.environment} userName={usernameForEnv} />
                 </TableCell>
                 <TableCell to={path}>
                   <RunStatus status={run.status} />

apps/webapp/app/hooks/usePostHog.ts

@@ -17,7 +17,7 @@ export const usePostHog = (apiKey?: string, logging = false, debug = false): voi
     if (postHogInitialized.current === true) return;
     if (logging) console.log("Initializing PostHog");
     posthog.init(apiKey, {
-      api_host: "https://app.posthog.com",
+      api_host: "https://eu.posthog.com",
       opt_in_site_apps: true,
       debug,
       loaded: function (posthog) {

apps/webapp/app/platform/zodWorker.server.ts

@@ -148,7 +148,7 @@ export class ZodWorker<TMessageCatalog extends MessageCatalogSchema> {
       return true;
     }
 
-    this.#logDebug("Initializing worker queue with options", {
+    this.#logDebug("Initializing graphile worker queue with options", {
       runnerOptions: this.#runnerOptions,
     });
 
@@ -163,7 +163,7 @@ export class ZodWorker<TMessageCatalog extends MessageCatalogSchema> {
     });
 
     if (!this.#runner) {
-      throw new Error("Failed to initialize worker queue");
+      throw new Error("Failed to initialize graphile worker queue");
     }
 
     this.#runner?.events.on("pool:create", ({ workerPool }) => {

apps/webapp/app/presenters/RunListPresenter.server.ts

@@ -1,6 +1,8 @@
+import { JobRunStatus, RuntimeEnvironmentType } from "@trigger.dev/database";
 import { z } from "zod";
 import { PrismaClient, prisma } from "~/db.server";
 import { DirectionSchema } from "~/routes/_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
+import { getUsername } from "~/utils/username";
 
 export type Direction = z.infer<typeof DirectionSchema>;
 
@@ -10,6 +12,8 @@ type RunListOptions = {
   organizationSlug: string;
   projectSlug: string;
   direction?: Direction;
+  filterStatus?: JobRunStatus[];
+  filterEnvironment?: RuntimeEnvironmentType;
   cursor?: string;
   pageSize?: number;
 };
@@ -30,6 +34,8 @@ export class RunListPresenter {
     jobSlug,
     organizationSlug,
     projectSlug,
+    filterEnvironment,
+    filterStatus,
     direction = "forward",
     cursor,
     pageSize = DEFAULT_PAGE_SIZE,
@@ -44,7 +50,6 @@ export class RunListPresenter {
       },
     });
 
-
     // Find the project scoped to the organization
     const project = await this.#prismaClient.project.findFirstOrThrow({
       where: {
@@ -57,19 +62,17 @@ export class RunListPresenter {
     const environments = await this.#prismaClient.runtimeEnvironment.findMany({
       where: {
         projectId: project.id,
-        OR: [
-          { orgMember: { userId } },
-          { orgMemberId: null },
-        ]
-      }
+      },
     });
 
-    const job = jobSlug ? await this.#prismaClient.job.findFirstOrThrow({
-      where: {
-        slug: jobSlug,
-        projectId: project.id,
-      },
-    }) : undefined;
+    const job = jobSlug
+      ? await this.#prismaClient.job.findFirstOrThrow({
+          where: {
+            slug: jobSlug,
+            projectId: project.id,
+          },
+        })
+      : undefined;
 
     const runs = await this.#prismaClient.jobRun.findMany({
       select: {
@@ -87,7 +90,13 @@ export class RunListPresenter {
             slug: true,
             orgMember: {
               select: {
-                userId: true,
+                user: {
+                  select: {
+                    id: true,
+                    name: true,
+                    displayName: true,
+                  },
+                },
               },
             },
           },
@@ -111,6 +120,8 @@ export class RunListPresenter {
         environmentId: {
           in: environments.map((environment) => environment.id),
         },
+        status: filterStatus ? { in: filterStatus } : undefined,
+        environment: filterEnvironment ? { type: filterEnvironment } : undefined,
       },
       orderBy: [{ id: "desc" }],
       //take an extra record to tell if there are more
@@ -119,8 +130,8 @@ export class RunListPresenter {
       skip: cursor ? 1 : 0,
       cursor: cursor
         ? {
-          id: cursor,
-        }
+            id: cursor,
+          }
         : undefined,
     });
 
@@ -163,7 +174,8 @@ export class RunListPresenter {
         environment: {
           type: run.environment.type,
           slug: run.environment.slug,
-          userId: run.environment.orgMember?.userId,
+          userId: run.environment.orgMember?.user.id,
+          userName: getUsername(run.environment.orgMember?.user),
         },
         job: run.job,
       })),

apps/webapp/app/presenters/RunPresenter.server.ts

@@ -8,6 +8,7 @@ import { PrismaClient, prisma } from "~/db.server";
 import { isRunCompleted, runBasicStatus } from "~/models/jobRun.server";
 import { mergeProperties } from "~/utils/mergeProperties.server";
 import { taskListToTree } from "~/utils/taskListToTree";
+import { getUsername } from "~/utils/username";
 
 type RunOptions = {
   id: string;
@@ -79,6 +80,8 @@ export class RunPresenter {
       environment: {
         type: run.environment.type,
         slug: run.environment.slug,
+        userId: run.environment.orgMember?.user.id,
+        userName: getUsername(run.environment.orgMember?.user),
       },
       event: this.#prepareEventData(run.event),
       tasks,
@@ -130,6 +133,17 @@ export class RunPresenter {
           select: {
             type: true,
             slug: true,
+            orgMember: {
+              select: {
+                user: {
+                  select: {
+                    id: true,
+                    name: true,
+                    displayName: true,
+                  },
+                },
+              },
+            },
           },
         },
         event: {

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route.tsx

@@ -10,6 +10,7 @@ import { RunsTable } from "~/components/runs/RunsTable";
 import { useJob } from "~/hooks/useJob";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
+import { useUser } from "~/hooks/useUser";
 import { RunListPresenter } from "~/presenters/RunListPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { cn } from "~/utils/cn";
@@ -57,6 +58,7 @@ export default function Page() {
   const organization = useOrganization();
   const project = useProject();
   const job = useJob();
+  const user = useUser();
 
   return (
     <>
@@ -81,6 +83,7 @@ export default function Page() {
                 runs={list.runs}
                 isLoading={isLoading}
                 runsParentPath={jobRunsParentPath(organization, project, job)}
+                currentUser={user}
               />
               <ListPagination list={list} className="mt-2 justify-end" />
             </div>

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam.runs.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { jobMatchId, useJob } from "~/hooks/useJob";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -63,6 +64,7 @@ export default function Page() {
   const organization = useOrganization();
   const project = useProject();
   const job = useJob();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(runStreamingPath(organization, project, job, run), {
@@ -86,6 +88,7 @@ export default function Page() {
         run: runPath(organization, project, job, run),
         runsPath: jobRunsParentPath(organization, project, job),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.runs/route.tsx

@@ -1,4 +1,4 @@
-import { useNavigation } from "@remix-run/react";
+import { useLocation, useNavigate, useNavigation } from "@remix-run/react";
 import { LoaderFunctionArgs } from "@remix-run/server-runtime";
 import { typedjson, useTypedLoaderData } from "remix-typedjson";
 import { PageBody, PageContainer } from "~/components/layout/AppLayout";
@@ -13,11 +13,72 @@ import {
 import { RunsTable } from "~/components/runs/RunsTable";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
+import { useUser } from "~/hooks/useUser";
 import { RunListPresenter } from "~/presenters/RunListPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { ProjectParamSchema, docsPath, projectPath } from "~/utils/pathBuilder";
 import { ListPagination } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination";
 import { RunListSearchSchema } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
+import {
+  Select,
+  SelectContent,
+  SelectGroup,
+  SelectItem,
+  SelectTrigger,
+  SelectValue,
+} from "~/components/primitives/Select";
+import { JobRunStatus, RuntimeEnvironmentType } from "@trigger.dev/database";
+import {
+  CheckCircleIcon,
+  ClockIcon,
+  ExclamationTriangleIcon,
+  PauseCircleIcon,
+  XCircleIcon,
+} from "@heroicons/react/24/solid";
+import { ChartBarIcon } from "@heroicons/react/20/solid";
+import { cn } from "~/utils/cn";
+import { Spinner } from "~/components/primitives/Spinner";
+import { NoSymbolIcon } from "@heroicons/react/20/solid";
+
+// Filter -> status types
+const ExtendedJobRunStatus = {
+  ALL: "ALL" as const,
+  ...JobRunStatus,
+} as const;
+type ExtendedJobRunStatusKey = keyof typeof ExtendedJobRunStatus;
+
+type FilterableStatus =
+  | "ALL"
+  | "QUEUED"
+  | "IN_PROGRESS"
+  | "WAITING"
+  | "COMPLETED"
+  | "FAILED"
+  | "CANCELED"
+  | "TIMEDOUT";
+
+const filterableStatuses: Record<FilterableStatus, ExtendedJobRunStatusKey[]> = {
+  ALL: ["ALL"],
+  QUEUED: ["QUEUED", "WAITING_TO_EXECUTE", "PENDING", "WAITING_ON_CONNECTIONS"],
+  IN_PROGRESS: ["STARTED", "EXECUTING", "PREPROCESSING"],
+  WAITING: ["WAITING_TO_CONTINUE"],
+  COMPLETED: ["SUCCESS"],
+  FAILED: ["FAILURE", "UNRESOLVED_AUTH", "INVALID_PAYLOAD", "ABORTED"],
+  TIMEDOUT: ["TIMED_OUT"],
+  CANCELED: ["CANCELED"],
+};
+
+const statusKeys: FilterableStatus[] = Object.keys(filterableStatuses) as FilterableStatus[];
+
+// Filter -> Environment types
+const ExtendedRuntimeEnvironment = {
+  ALL: "ALL" as const,
+  ...RuntimeEnvironmentType,
+} as const;
+type ExtendedRuntimeEnvironmentType = keyof typeof ExtendedRuntimeEnvironment;
+const environmentKeys: ExtendedRuntimeEnvironmentType[] = Object.keys(
+  ExtendedRuntimeEnvironment
+) as ExtendedRuntimeEnvironmentType[];
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const userId = await requireUserId(request);
@@ -27,9 +88,29 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const s = Object.fromEntries(url.searchParams.entries());
   const searchParams = RunListSearchSchema.parse(s);
 
+  const status = url.searchParams.get("status");
+  const environment = url.searchParams.get("environment");
+
+  let filterStatus: JobRunStatus[] | undefined;
+  if (status && status !== "ALL") {
+    if (filterableStatuses.hasOwnProperty(status)) {
+      filterStatus = filterableStatuses[status as FilterableStatus] as JobRunStatus[];
+    }
+  }
+
+  let filterEnvironment: RuntimeEnvironmentType | undefined;
+  if (environment && environment !== "ALL") {
+    if (environmentKeys.includes(environment)) {
+      filterEnvironment = environment as RuntimeEnvironmentType;
+    }
+  }
+
   const presenter = new RunListPresenter();
+
   const list = await presenter.call({
     userId,
+    filterEnvironment: filterEnvironment,
+    filterStatus: filterStatus,
     projectSlug: projectParam,
     organizationSlug,
     direction: searchParams.direction,
@@ -48,6 +129,28 @@ export default function Page() {
   const isLoading = navigation.state !== "idle";
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
+  const navigate = useNavigate();
+  const location = useLocation();
+  const url = new URLSearchParams(location.search);
+
+  const selectedEnvironment = url.get("environment") || ExtendedRuntimeEnvironment.ALL;
+  const selectedStatus = url.get("status") || ExtendedJobRunStatus.ALL;
+
+  const handleFilterChange = (filterType: string, value: string) => {
+    url.set(filterType, value);
+    url.delete("cursor");
+    url.delete("direction");
+    navigate(`${location.pathname}?${url.toString()}`);
+  };
+
+  const handleStatusChange = (value: FilterableStatus) => {
+    handleFilterChange("status", value);
+  };
+
+  const handleEnvironmentChange = (value: string) => {
+    handleFilterChange("environment", value);
+  };
 
   return (
     <PageContainer>
@@ -69,7 +172,68 @@ export default function Page() {
 
       <PageBody scrollable={false}>
         <div className="h-full overflow-y-auto p-4 scrollbar-thin scrollbar-track-transparent scrollbar-thumb-slate-700">
-          <div className="mb-2 flex items-center justify-end gap-x-2">
+          <div className="mb-2 flex items-center justify-between gap-x-2">
+            <div className="flex flex-row justify-between gap-x-2">
+              {/* environment filter */}
+              <SelectGroup>
+                <Select
+                  name="environment"
+                  value={selectedEnvironment}
+                  onValueChange={handleEnvironmentChange}
+                >
+                  <SelectTrigger size="secondary/small" width="full">
+                    <SelectValue placeholder="Select environment" className="ml-2 p-0" />
+                  </SelectTrigger>
+                  <SelectContent>
+                    {environmentKeys.map((env) => (
+                      <SelectItem key={env} value={env}>
+                        <div className="flex gap-x-2">
+                          {env !== "ALL" && (
+                            <span
+                              className={cn(
+                                "inline-flex h-4 items-center justify-center rounded-[2px] px-1 text-xxs font-medium uppercase tracking-wider text-midnight-900",
+                                filterEnvironmentColorClassName(env)
+                              )}
+                            >
+                              {filterEnvironmentTitle(env)}
+                            </span>
+                          )}
+                          <span
+                            className={cn(
+                              "inline-flex h-4 items-center justify-center pl-1 text-xxs font-medium uppercase tracking-wider text-dimmed"
+                            )}
+                          >
+                            {env === "ALL" ? env + " Environments" : env}
+                          </span>
+                        </div>
+                      </SelectItem>
+                    ))}
+                  </SelectContent>
+                </Select>
+              </SelectGroup>
+
+              {/* status filter */}
+              <SelectGroup>
+                <Select name="status" value={selectedStatus} onValueChange={handleStatusChange}>
+                  <SelectTrigger size="secondary/small" width="full">
+                    <SelectValue placeholder="Select environment" className="ml-2 p-0" />
+                  </SelectTrigger>
+                  <SelectContent>
+                    {statusKeys.map((status) => (
+                      <SelectItem key={status} value={status}>
+                        {
+                          <span className="flex items-center gap-1 text-xxs font-medium uppercase tracking-wider">
+                            <FilterStatusIcon status={status} className="h-4 w-4" />
+                            <FilterStatusLabel status={status} />
+                          </span>
+                        }
+                      </SelectItem>
+                    ))}
+                  </SelectContent>
+                </Select>
+              </SelectGroup>
+            </div>
+
             <ListPagination list={list} />
           </div>
           <RunsTable
@@ -79,6 +243,7 @@ export default function Page() {
             runs={list.runs}
             isLoading={isLoading}
             runsParentPath={projectPath(organization, project)}
+            currentUser={user}
           />
           <ListPagination list={list} className="mt-2 justify-end" />
         </div>
@@ -86,3 +251,120 @@ export default function Page() {
     </PageContainer>
   );
 }
+
+function filterEnvironmentTitle(environment: ExtendedRuntimeEnvironmentType) {
+  switch (environment) {
+    case "ALL":
+      return "All";
+    case "PRODUCTION":
+      return "Prod";
+    case "STAGING":
+      return "Staging";
+    case "DEVELOPMENT":
+      return "Dev";
+    case "PREVIEW":
+      return "Preview";
+  }
+}
+
+function filterEnvironmentColorClassName(environment: ExtendedRuntimeEnvironmentType) {
+  switch (environment) {
+    case "ALL":
+      return "bg-indigo-500";
+    case "PRODUCTION":
+      return "bg-green-500";
+    case "STAGING":
+      return "bg-amber-500";
+    case "DEVELOPMENT":
+      return "bg-pink-500";
+    case "PREVIEW":
+      return "bg-yellow-500";
+  }
+}
+
+export function FilterStatusLabel({ status }: { status: FilterableStatus }) {
+  return <span className={filterStatusClassNameColor(status)}>{filterStatusTitle(status)}</span>;
+}
+
+export function FilterStatusIcon({
+  status,
+  className,
+}: {
+  status: FilterableStatus;
+  className: string;
+}) {
+  switch (status) {
+    case "ALL":
+      return <span className="w-[0.0625rem]"></span>;
+    case "COMPLETED":
+      return <CheckCircleIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "WAITING":
+      return <ClockIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "QUEUED":
+      return <PauseCircleIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "IN_PROGRESS":
+      return <Spinner className={cn(filterStatusClassNameColor(status), className)} />;
+    case "TIMEDOUT":
+      return (
+        <ExclamationTriangleIcon className={cn(filterStatusClassNameColor(status), className)} />
+      );
+    case "CANCELED":
+      return <NoSymbolIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "FAILED":
+      return <XCircleIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    default: {
+      const _exhaustiveCheck: never = status;
+      throw new Error(`Non-exhaustive match for value: ${status}`);
+    }
+  }
+}
+
+export function filterStatusTitle(status: FilterableStatus): string {
+  switch (status) {
+    case "ALL":
+      return "All Status";
+    case "QUEUED":
+      return "Queued";
+    case "IN_PROGRESS":
+      return "In progress";
+    case "WAITING":
+      return "Waiting";
+    case "COMPLETED":
+      return "Completed";
+    case "FAILED":
+      return "Failed";
+    case "CANCELED":
+      return "Canceled";
+    case "TIMEDOUT":
+      return "Timed out";
+    default: {
+      const _exhaustiveCheck: never = status;
+      throw new Error(`Non-exhaustive match for value: ${status}`);
+    }
+  }
+}
+
+export function filterStatusClassNameColor(status: FilterableStatus): string {
+  switch (status) {
+    case "ALL":
+      return "text-dimmed";
+    case "QUEUED":
+      return "text-slate-500";
+    case "IN_PROGRESS":
+      return "text-blue-500";
+    case "WAITING":
+      return "text-blue-500";
+    case "COMPLETED":
+      return "text-green-500";
+    case "FAILED":
+      return "text-rose-500";
+    case "CANCELED":
+      return "text-slate-500";
+    case "TIMEDOUT":
+      return "text-amber-300";
+    default: {
+      const _exhaustiveCheck: never = status;
+      throw new Error(`Non-exhaustive match for value: ${status}`);
+    }
+  }
+}

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.external.$triggerParam/route.tsx

@@ -44,6 +44,7 @@ import { z } from "zod";
 import { ActivateSourceService } from "~/services/sources/activateSource.server";
 import { redirectWithSuccessMessage } from "~/models/message.server";
 import { nanoid } from "nanoid";
+import { useUser } from "~/hooks/useUser";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const user = await requireUser(request);
@@ -130,6 +131,7 @@ export default function Page() {
   const { trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
   const navigation = useNavigation();
   const lastSubmission = useActionData();
 
@@ -234,6 +236,7 @@ export default function Page() {
                 total={trigger.runList.runs.length}
                 hasFilters={false}
                 runsParentPath={externalTriggerRunsParentPath(organization, project, trigger)}
+                currentUser={user}
               />
               <ListPagination list={trigger.runList} className="mt-2 justify-end" />
             </>

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.external.$triggerParam_.runs.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { prisma } from "~/db.server";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -97,6 +98,7 @@ export default function Page() {
   const { run, trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(
@@ -124,6 +126,7 @@ export default function Page() {
           id: trigger.id,
         }),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam._index/route.tsx

@@ -9,6 +9,7 @@ import { Paragraph } from "~/components/primitives/Paragraph";
 import { RunsTable } from "~/components/runs/RunsTable";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
+import { useUser } from "~/hooks/useUser";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
 import { requireUser, requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -105,10 +106,7 @@ export const handle: Handle = {
         <BreadcrumbIcon />
         <BreadcrumbLink to={projectWebhookTriggersPath(org, project)} title="Webhook Triggers" />
         <BreadcrumbIcon />
-        <BreadcrumbLink
-          to={trimTrailingSlash(match.pathname)}
-          title={data.trigger.key}
-        />
+        <BreadcrumbLink to={trimTrailingSlash(match.pathname)} title={data.trigger.key} />
       </Fragment>
     );
   },
@@ -118,6 +116,7 @@ export default function Page() {
   const { trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
   const navigation = useNavigation();
   const lastSubmission = useActionData();
 
@@ -135,17 +134,17 @@ export default function Page() {
   return (
     <>
       <Paragraph variant="small" spacing>
-        Webhook Triggers need to be registered with the external service. You can see the list
-        of attempted registrations below.
+        Webhook Triggers need to be registered with the external service. You can see the list of
+        attempted registrations below.
       </Paragraph>
 
-      {!trigger.active &&
+      {!trigger.active && (
         <Form method="post" {...form.props}>
-        <Callout variant="error" className="justiy-between mb-4 items-center">
-          <Paragraph variant="small" className={cn(variantClasses.error.textColor, "grow")}>
-            Registration hasn't succeeded yet, check the runs below.
-          </Paragraph>
-          {/* <input
+          <Callout variant="error" className="justiy-between mb-4 items-center">
+            <Paragraph variant="small" className={cn(variantClasses.error.textColor, "grow")}>
+              Registration hasn't succeeded yet, check the runs below.
+            </Paragraph>
+            {/* <input
             {...conform.input(jobId, { type: "hidden" })}
             defaultValue={trigger.registrationJob?.id}
           />
@@ -159,8 +158,9 @@ export default function Page() {
           >
             {isLoading ? "Retrying…" : "Retry now"}
           </Button> */}
-        </Callout>
-      </Form>}
+          </Callout>
+        </Form>
+      )}
 
       {trigger.runList ? (
         <>
@@ -170,6 +170,7 @@ export default function Page() {
             total={trigger.runList.runs.length}
             hasFilters={false}
             runsParentPath={webhookTriggerRunsParentPath(organization, project, trigger)}
+            currentUser={user}
           />
           <ListPagination list={trigger.runList} className="mt-2 justify-end" />
         </>

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam_.runs.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { prisma } from "~/db.server";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -103,6 +104,7 @@ export default function Page() {
   const { run, trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(
@@ -130,6 +132,7 @@ export default function Page() {
           id: trigger.id,
         }),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam_.runs.delivery.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { prisma } from "~/db.server";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -83,7 +84,10 @@ export const handle: Handle = {
           title={`${data.trigger.integration.title}: ${data.trigger.integration.slug}`}
         />
         <BreadcrumbIcon />
-        <BreadcrumbLink to={webhookDeliveryPath(org, project, { id: data.trigger.id })} title="Deliveries" />
+        <BreadcrumbLink
+          to={webhookDeliveryPath(org, project, { id: data.trigger.id })}
+          title="Deliveries"
+        />
         <BreadcrumbIcon />
         {data && data.run && (
           <BreadcrumbLink
@@ -100,6 +104,7 @@ export default function Page() {
   const { run, trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(
@@ -127,6 +132,7 @@ export default function Page() {
           id: trigger.id,
         }),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/api.v1.jobs.$jobSlug.cancel-runs.ts

@@ -0,0 +1,48 @@
+import type { ActionFunctionArgs } from "@remix-run/server-runtime";
+import { json } from "@remix-run/server-runtime";
+import { z } from "zod";
+import { authenticateApiRequest } from "~/services/apiAuth.server";
+import { logger } from "~/services/logger.server";
+import { CancelRunsForJobService } from "~/services/jobs/cancelRunsForJob.server";
+
+const ParamsSchema = z.object({
+  jobSlug: z.string(),
+});
+
+export async function action({ request, params }: ActionFunctionArgs) {
+  // Ensure this is a POST request
+  if (request.method.toUpperCase() !== "POST") {
+    return { status: 405, body: "Method Not Allowed" };
+  }
+
+  // Next authenticate the request
+  const authenticationResult = await authenticateApiRequest(request);
+
+  if (!authenticationResult) {
+    return json({ error: "Invalid or Missing API key" }, { status: 401 });
+  }
+
+  const authenticatedEnv = authenticationResult.environment;
+
+  const parsed = ParamsSchema.safeParse(params);
+
+  if (!parsed.success) {
+    return json({ error: "Invalid or Missing jobSlug" }, { status: 400 });
+  }
+
+  const { jobSlug } = parsed.data;
+
+  const service = new CancelRunsForJobService();
+  try {
+    const res = await service.call(authenticatedEnv, jobSlug);
+
+    if (!res) {
+      return json({ error: "Job not found" }, { status: 404 });
+    }
+
+    return json(res);
+  } catch (err) {
+    logger.error("CancelRunsForJobService.call() error", { error: err });
+    return json({ error: "Internal Server Error" }, { status: 500 });
+  }
+}

apps/webapp/app/services/externalApis/apis.server.ts

@@ -48,18 +48,25 @@ export const apisList = [
     identifier: "anthropic",
     name: "Anthropic",
   },
-  {
-    identifier: "appsmith",
-    name: "Appsmith",
-  },
-  {
-    identifier: "appwrite",
-    name: "Appwrite",
-  },
+  // {
+  //   identifier: "appsmith",
+  //   name: "Appsmith",
+  // },
+  // {
+  //   identifier: "appwrite",
+  //   name: "Appwrite",
+  // },
   {
     identifier: "asana",
     name: "Asana",
     examples: [
+      {
+        title: "A job that is triggered by a Asana webhook.",
+        slug: "asana-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/asana-http-endpoint.ts",
+      },
       {
         title: "Get user details from Asana",
         slug: "get-user-details",
@@ -68,10 +75,6 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "atlassian",
-    name: "Atlassian",
-  },
   {
     identifier: "aws",
     name: "AWS",
@@ -82,12 +85,26 @@ export const apisList = [
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/aws.ts",
       },
+      {
+        title: "A job that is triggered by an AWS webhook.",
+        slug: "aws-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/aws-http-endpoint.ts",
+      },
     ],
   },
   {
     identifier: "brex",
     name: "Brex",
     examples: [
+      {
+        title: "A job that is triggered by a Brex webhook.",
+        slug: "brex-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/brex-http-endpoint.ts",
+      },
       {
         title: "Create a new title in a Brex account.",
         slug: "create-new-brex-title",
@@ -151,38 +168,66 @@ export const apisList = [
       },
     ],
   },
+
+  {
+    identifier: "digitalocean",
+    name: "DigitalOcean",
+    examples: [
+      {
+        title: "DigitalOcean create Uptime",
+        slug: "digitalocean-create-uptime",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/digitalocean.ts",
+      },
+    ],
+  },
   {
     identifier: "discord",
     name: "Discord",
     examples: [
+      {
+        title: "A job that is triggered by a Discord webhook.",
+        slug: "discord-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/discord-http-endpoint.ts",
+      },
       {
         title: "Create a Discord bot and send a message to a channel.",
         slug: "discord-bot-send-message",
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/discord.ts",
       },
+      {
+        title: "A job that is triggered by a Discord webhook.",
+        slug: "discord-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/discord-http-endpoint.ts",
+      },
     ],
   },
-  {
-    identifier: "documenso",
-    name: "Documenso",
-  },
-  {
-    identifier: "dropbox",
-    name: "Dropbox",
-  },
-  {
-    identifier: "facebook",
-    name: "Facebook",
-  },
-  {
-    identifier: "fastify",
-    name: "Fastify",
-  },
-  {
-    identifier: "flickr",
-    name: "Flickr",
-  },
+  // {
+  //   identifier: "documenso",
+  //   name: "Documenso",
+  // },
+  // {
+  //   identifier: "dropbox",
+  //   name: "Dropbox",
+  // },
+  // {
+  //   identifier: "facebook",
+  //   name: "Facebook",
+  // },
+  // {
+  //   identifier: "fastify",
+  //   name: "Fastify",
+  // },
+  // {
+  //   identifier: "flickr",
+  //   name: "Flickr",
+  // },
   {
     identifier: "github",
     name: "GitHub",
@@ -233,6 +278,13 @@ export const apisList = [
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/gmail.ts",
       },
+      {
+        title: "A job that is triggered by a Gmail webhook.",
+        slug: "gmail-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/gmail-http-endpoint.ts",
+      },
     ],
   },
   {
@@ -250,11 +302,27 @@ export const apisList = [
   {
     identifier: "googledocs",
     name: "Google Docs",
+    examples: [
+      {
+        title: "A job that is triggered by a Google Docs webhook.",
+        slug: "google-docs-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/google-docs-http-endpoint.ts",
+      },
+    ],
   },
   {
     identifier: "googledrive",
     name: "Google Drive",
     examples: [
+      {
+        title: "A job that is triggered by a Google Drive webhook.",
+        slug: "google-drive-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/google-drive-http-endpoint.ts",
+      },
       {
         title: "Update a filename in Google Drive.",
         slug: "update-google-drive-filename",
@@ -279,6 +347,13 @@ export const apisList = [
     identifier: "googlesheets",
     name: "Google Sheets",
     examples: [
+      {
+        title: "A job that is triggered by a Google Sheets webhook.",
+        slug: "google-sheets-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/google-sheets-http-endpoint.ts",
+      },
       {
         title: "Insert data into a row in Google Sheets.",
         slug: "insert-data-into-google-sheets",
@@ -333,6 +408,13 @@ export const apisList = [
     identifier: "instagram",
     name: "Instagram",
     examples: [
+      {
+        title: "A job that is triggered by a Instagram webhook.",
+        slug: "instagram-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/instagram-http-endpoint.ts",
+      },
       {
         title: "Post an image to Instagram",
         slug: "post-image-to-instagram",
@@ -341,14 +423,14 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "instabug",
-    name: "Instabug",
-  },
-  {
-    identifier: "keep",
-    name: "Keep",
-  },
+  // {
+  //   identifier: "instabug",
+  //   name: "Instabug",
+  // },
+  // {
+  //   identifier: "keep",
+  //   name: "Keep",
+  // },
   {
     identifier: "lemonsqueezy",
     name: "Lemon Squeezy",
@@ -361,10 +443,10 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "linkedin",
-    name: "LinkedIn",
-  },
+  // {
+  //   identifier: "linkedin",
+  //   name: "LinkedIn",
+  // },
   {
     identifier: "linear",
     name: "Linear",
@@ -404,10 +486,10 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "lotus",
-    name: "Lotus",
-  },
+  // {
+  //   identifier: "lotus",
+  //   name: "Lotus",
+  // },
   {
     identifier: "mailchimp",
     name: "Mailchimp",
@@ -434,6 +516,15 @@ export const apisList = [
   {
     identifier: "microsoftazure",
     name: "Microsoft Azure",
+    examples: [
+      {
+        title: "A job that is triggered by a Microsoft Azure webhook.",
+        slug: "microsoft-azure-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/azure-http-endpoint.ts",
+      },
+    ],
   },
   {
     identifier: "monday",
@@ -503,6 +594,22 @@ export const apisList = [
   {
     identifier: "pagerduty",
     name: "PagerDuty",
+    examples: [
+      {
+        title: "A job that is triggered by a PagerDuty webhook.",
+        slug: "pagerduty-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/pagerduty-http-endpoint.ts",
+      },
+      {
+        title: "Install an addon in PagerDuty",
+        slug: "pagerduty-install-addon",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/pagerduty.ts",
+      },
+    ],
   },
   {
     identifier: "plain",
@@ -517,10 +624,10 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "posthog",
-    name: "Posthog",
-  },
+  // {
+  //   identifier: "posthog",
+  //   name: "Posthog",
+  // },
   {
     identifier: "raycast",
     name: "Raycast",
@@ -573,6 +680,13 @@ export const apisList = [
     identifier: "salesforce",
     name: "Salesforce",
     examples: [
+      {
+        title: "A job that is triggered by a Salesforce webhook.",
+        slug: "salesforce-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/salesforce-http-endpoint.ts",
+      },
       {
         title: "Create a new contact in Salesforce.",
         slug: "salesforce-create-contact",
@@ -585,6 +699,13 @@ export const apisList = [
     identifier: "segment",
     name: "Segment",
     examples: [
+      {
+        title: "A job that is triggered by a Segment webhook.",
+        slug: "segment-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/segment-http-endpoint.ts",
+      },
       {
         title: "Get source information from Segment.",
         slug: "segment-get-source-information",
@@ -671,6 +792,13 @@ export const apisList = [
     identifier: "snyk",
     name: "Snyk",
     examples: [
+      {
+        title: "A job that is triggered by a Snyk webhook.",
+        slug: "snyk-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/snyk-http-endpoint.ts",
+      },
       {
         title: "Get user details from Snyk.",
         slug: "snyk-get-user-details",
@@ -679,6 +807,19 @@ export const apisList = [
       },
     ],
   },
+  {
+    identifier: "square",
+    name: "Square",
+    examples: [
+      {
+        title: "A job that is triggered by a Square webhook.",
+        slug: "square-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/square-http-endpoint.ts",
+      },
+    ],
+  },
   {
     identifier: "spotify",
     name: "Spotify",
@@ -739,6 +880,16 @@ export const apisList = [
     identifier: "svix",
     name: "Svix",
     examples: [
+      {
+        title: "A job that is triggered by a Svix webhook.",
+        slug: "svix-http-endpoint",
+        version: "1.0.0",
+        exampleType: ["http-endpoint"],
+        apisUsed: ["svix"],
+        tags: ["dev-ops"],
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/svix-http-endpoint.ts",
+      },
       {
         title: "Create an application in Svix",
         slug: "svix-create-application",
@@ -751,6 +902,13 @@ export const apisList = [
     identifier: "todoist",
     name: "Todoist",
     examples: [
+      {
+        title: "A job that is triggered by a Todoist webhook.",
+        slug: "todoist-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/todoist-http-endpoint.ts",
+      },
       {
         title: "Add a new project in Todoist.",
         slug: "todoist-add-new-project",
@@ -774,6 +932,13 @@ export const apisList = [
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/twilio.ts",
       },
+      {
+        title: "A job that is triggered by a Twilio webhook.",
+        slug: "twilio-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/twilio-http-endpoint.ts",
+      },
     ],
   },
   {
@@ -825,6 +990,13 @@ export const apisList = [
     identifier: "youtube",
     name: "YouTube",
     examples: [
+      {
+        title: "A job that is triggered by a YouTube webhook.",
+        slug: "youtube-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/youtube-http-endpoint.ts",
+      },
       {
         title: "Search for a YouTube video",
         slug: "youtube-search-video",
@@ -833,6 +1005,25 @@ export const apisList = [
       },
     ],
   },
+  {
+    identifier: "zapier",
+    name: "Zapier",
+    examples: [
+      {
+        title: "Store name in Zapier",
+        slug: "zapier-store-name",
+        version: "1.0.0",
+        codeUrl: "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/zapier.ts",
+      },
+      {
+        title: "A job that is triggered by a Zapier webhook.",
+        slug: "zapier-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/zapier-http-endpoint.ts",
+      },
+    ],
+  },
   {
     identifier: "zbd",
     name: "ZBD",

apps/webapp/app/services/jobs/cancelRunsForJob.server.ts

@@ -0,0 +1,73 @@
+import { $transaction, PrismaClient, prisma } from "~/db.server";
+import { AuthenticatedEnvironment } from "../apiAuth.server";
+import { JobRunStatus } from "@trigger.dev/database";
+import { CancelRunService } from "../runs/cancelRun.server";
+import { logger } from "../logger.server";
+import { CancelRunsForJob } from "@trigger.dev/core";
+
+const CANCELLABLE_JOB_RUN_STATUS: JobRunStatus[] = [
+  JobRunStatus.PENDING,
+  JobRunStatus.QUEUED,
+  JobRunStatus.WAITING_ON_CONNECTIONS,
+  JobRunStatus.PREPROCESSING,
+  JobRunStatus.STARTED,
+  JobRunStatus.EXECUTING,
+  JobRunStatus.WAITING_TO_CONTINUE,
+  JobRunStatus.WAITING_TO_EXECUTE,
+];
+
+export class CancelRunsForJobService {
+  #prismaClient: PrismaClient;
+
+  constructor(prismaClient: PrismaClient = prisma) {
+    this.#prismaClient = prismaClient;
+  }
+
+  public async call(environment: AuthenticatedEnvironment, jobSlug: string) {
+    return await $transaction<CancelRunsForJob | undefined>(this.#prismaClient, async (tx) => {
+      const job = await tx.job.findUnique({
+        where: {
+          projectId_slug: {
+            projectId: environment.projectId,
+            slug: jobSlug,
+          },
+        },
+      });
+
+      if (!job) {
+        return;
+      }
+
+      const jobRuns = await tx.jobRun.findMany({
+        where: {
+          jobId: job.id,
+          status: {
+            in: CANCELLABLE_JOB_RUN_STATUS,
+          },
+        },
+        select: {
+          id: true,
+        },
+      });
+
+      const cancelRunService = new CancelRunService(this.#prismaClient);
+      const cancelledRunIds: string[] = [];
+      const failedToCancelRunIds: string[] = [];
+
+      for (const jobRun of jobRuns) {
+        try {
+          await cancelRunService.call({ runId: jobRun.id });
+          cancelledRunIds.push(jobRun.id);
+        } catch (err) {
+          logger.debug(`failed to cancel job run with id ${jobRun.id} for job ${jobSlug}`);
+          failedToCancelRunIds.push(jobRun.id);
+        }
+      }
+
+      return {
+        cancelledRunIds: cancelledRunIds,
+        failedToCancelRunIds: failedToCancelRunIds,
+      };
+    });
+  }
+}

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

@@ -22,7 +22,7 @@ class Telemetry {
 
   constructor({ postHogApiKey, trigger }: Options) {
     if (postHogApiKey) {
-      this.#posthogClient = new PostHog(postHogApiKey, { host: "https://app.posthog.com" });
+      this.#posthogClient = new PostHog(postHogApiKey, { host: "https://eu.posthog.com" });
     } else {
       console.log("No PostHog API key, so analytics won't track");
     }

apps/webapp/app/utils/username.ts

@@ -0,0 +1,22 @@
+import type { User as DBUser } from "~/models/user.server";
+
+type User = Pick<DBUser, "name" | "displayName">;
+
+// remove `null` from username
+export function getUsername(user?: User): string | undefined {
+  if (!user) {
+    return;
+  }
+
+  // user.displayName is of type `string | null`
+  if (user.displayName) {
+    return user.displayName;
+  }
+
+  // user.name is of type `string | null`
+  if (user.name) {
+    return user.name;
+  }
+
+  return;
+}

apps/webapp/package.json

@@ -66,8 +66,8 @@
     "@tabler/icons-react": "^2.39.0",
     "@tailwindcss/container-queries": "^0.1.1",
     "@team-plain/typescript-sdk": "^3.5.0",
+    "@trigger.dev/companyicons": "^1.5.35",
     "@trigger.dev/billing": "^1.0.10",
-    "@trigger.dev/companyicons": "^1.5.32",
     "@trigger.dev/core": "workspace:*",
     "@trigger.dev/core-backend": "workspace:*",
     "@trigger.dev/database": "workspace:*",
@@ -99,8 +99,8 @@
     "nanoid": "^3.3.4",
     "ohash": "^1.1.3",
     "postcss-import": "^14.1.0",
-    "posthog-js": "^1.83.0",
-    "posthog-node": "^3.1.1",
+    "posthog-js": "^1.93.3",
+    "posthog-node": "^3.1.3",
     "prism-react-renderer": "^1.3.5",
     "prismjs": "^1.29.0",
     "random-words": "^2.0.0",

docker/Dockerfile

@@ -1,4 +1,4 @@
-FROM node:18.18.2-bullseye-slim@sha256:a50436b44fe3eb2ff72696fb394ad3cae45f06cb2a7468c5ef3f012d23d9888f AS pruner
+FROM node:18.18.2-bullseye-slim@sha256:21479df46c3173ee0cefc6b264928e10239152c4f74df872ca9369be01a245b7 AS pruner
 
 WORKDIR /triggerdotdev
 
@@ -7,7 +7,7 @@ RUN npx -q turbo@1.10.9 prune --scope=webapp --docker
 RUN find . -name "node_modules" -type d -prune -exec rm -rf '{}' +
 
 # Base strategy to have layer caching
-FROM node:18.18.2-bullseye-slim@sha256:a50436b44fe3eb2ff72696fb394ad3cae45f06cb2a7468c5ef3f012d23d9888f AS base
+FROM node:18.18.2-bullseye-slim@sha256:21479df46c3173ee0cefc6b264928e10239152c4f74df872ca9369be01a245b7 AS base
 RUN apt-get update && apt-get install -y openssl dumb-init
 WORKDIR /triggerdotdev
 COPY --chown=node:node .gitignore .gitignore
@@ -50,7 +50,7 @@ RUN pnpm run generate
 RUN pnpm run build --filter=webapp...
 
 # Runner
-FROM node:18.18.2-bullseye-slim@sha256:a50436b44fe3eb2ff72696fb394ad3cae45f06cb2a7468c5ef3f012d23d9888f AS runner
+FROM node:18.18.2-bullseye-slim@sha256:21479df46c3173ee0cefc6b264928e10239152c4f74df872ca9369be01a245b7 AS runner
 RUN apt-get update && apt-get install -y openssl
 WORKDIR /triggerdotdev
 RUN corepack enable

docs/_snippets/manual-setup-express.mdx

@@ -81,6 +81,7 @@ const app: Express = express();
 
 //add the middleware
 app.use(createMiddleware(client));
+// app.use(express.json()); //if you're parsing JSON, you need to add the Trigger middleware before this
 
 //..the rest of your Express code
 ```

docs/_snippets/quickstart-whats-next.mdx

@@ -11,8 +11,9 @@
   >
     Learn more about how Trigger.dev works and how it can help you.
   </Card>
-  <Card title="Examples" icon="slot-machine" href="/examples">
-    One of the quickest ways to learn how Trigger.dev works is to view some example Jobs.
+  <Card title="Examples" icon="slot-machine" href="https:/trigger.dev/apis">
+    Find code examples for many popular APIs. These can be copied / modified for use in your own
+    projects.
   </Card>
   <Card title="Get help" icon="hire-a-helper" href="/documentation/get-help">
     Struggling getting setup or have a question? We're here to help.

docs/documentation/guides/writing-jobs-step-by-step.mdx

@@ -372,7 +372,7 @@ We recommend exploring all of the below sections to fully understand how to crea
   Integrations make it easy to authenticate and use APIs. Learn how to use and create integrations.
 </Card>
 <Card title="API catalog with code samples" icon="code" href="https://trigger.dev/apis">
-  Find code examples for the API you need that you can copy and paste into your
+  Find code examples for many popular APIs. These can be copied / modified for use in your own
   projects.
 </Card>
 <Card title="SDK reference" icon="book-open" href="/sdk">

docs/documentation/introduction.mdx

@@ -30,8 +30,9 @@ You can use [Trigger.dev Cloud](https://cloud.trigger.dev) or [Self-host Trigger
   <Card title="Integrations" icon="grid-2" href="/integrations">
     Trigger.dev integrates with a wide range of services.
   </Card>
-  <Card title="Examples" icon="slot-machine" href="/examples">
-    One of the quickest ways to learn how Trigger.dev works is to view some example Jobs.
+  <Card title="Examples - API catalog" icon="code" href="https://trigger.dev/apis">
+    Find code examples for many popular APIs. These can be copied / modified for use in your own
+    projects.
   </Card>
   <Card title="Manual Setup" icon="book-sparkles" href="guides/manual">
     For complete control, you can manually setup Trigger.dev using this guide.
@@ -54,7 +55,10 @@ We'd love to hear from you or give you a hand getting started. Here are some way
   </Card>
   <Card
     title="Follow us on X (Twitter)"
-    icon={<svg xmlns="http://www.w3.org/2000/svg" height="20" viewBox="0 0 512 512"><path d="M389.2 48h70.6L305.6 224.2 487 464H345L233.7 318.6 106.5 464H35.8L200.7 275.5 26.8 48H172.4L272.9 180.9 389.2 48zM364.4 421.8h39.1L151.1 88h-42L364.4 421.8z"/></svg>
+    icon={
+      <svg xmlns="http://www.w3.org/2000/svg" height="20" viewBox="0 0 512 512">
+        <path d="M389.2 48h70.6L305.6 224.2 487 464H345L233.7 318.6 106.5 464H35.8L200.7 275.5 26.8 48H172.4L272.9 180.9 389.2 48zM364.4 421.8h39.1L151.1 88h-42L364.4 421.8z" />
+      </svg>
     }
     href="https://twitter.com/triggerdotdev"
     color="#1DA1F2"

docs/documentation/quickstarts/hono.mdx

@@ -213,20 +213,27 @@ export default app;
 
 ### Deno
 
-Deno works similarly to Bun, but the imports are slightly different. First, import the `@trigger.dev/sdk` and `@trigger.dev/hono` packages using [npm: specifiers](https://docs.deno.com/runtime/manual/node/npm_specifiers)
-
+Import trigger.dev packages with Deno using [npm: specifiers](https://docs.deno.com/runtime/manual/node/npm_specifiers):
 ```ts index.ts
 import { createMiddleware } from "npm:@trigger.dev/hono@latest";
 import { TriggerClient, invokeTrigger } from "npm:@trigger.dev/sdk@latest";
 import { Hono } from "npm:hono"; // Make sure to use the npm specifier for hono as well
 ```
 
-Deno doesn't automatically load environment variables from a `.env` file, so you'll need to load them manually using the `dotenv` package:
+To load a `.env` file on startup, pass the `deno run` command a `--env` flag:
+```bash
+deno run --env --allow-net --watch index.ts
+```
 
+You can also load an environment variables file in code using the `dotenv` package:
 ```ts index.ts
 import { load } from "https://deno.land/std@0.208.0/dotenv/mod.ts";
 const env = await load();
 ```
+In which case you need to pass the `--allow-env` and `--allow-read` flags:
+```bash
+deno run --allow-env --allow-net --allow-read --watch index.ts
+```
 
 Now we can create the `TriggerClient`, define our jobs, and create the middleware:
 
@@ -373,7 +380,7 @@ yarn dlx @trigger.dev/cli@latest dev --client-id hono-client -p 8787 -H localhos
 Run your Hono app locally, like you normally would. For example:
 
 ```bash
-deno run --allow-net --allow-read --watch index.ts
+deno run --env --allow-net --watch index.ts
 ```
 
 In a **_separate terminal window or tab_** run:

docs/examples/introduction.mdx

@@ -5,7 +5,8 @@ description: "Jobs and code examples you can use to get started."
 
 <CardGroup>
   <Card title="API catalog with code samples" icon="code" href="https://trigger.dev/apis">
-    Find code examples for the API you need that you can copy and paste into your projects.
+    Find code examples for many popular APIs. These can be copied / modified for use in your own
+    projects.
   </Card>
   <Card
     title="Browse our Project Showcase"

docs/mint.json

@@ -1,9 +1,7 @@
 {
   "$schema": "https://mintlify.com/schema.json",
   "name": "Trigger.dev",
-  "openapi": [
-    "/openapi.yml"
-  ],
+  "openapi": ["/openapi.yml"],
   "logo": {
     "dark": "/logo/dark.png",
     "light": "/logo/light.png",
@@ -49,8 +47,8 @@
       "url": "sdk"
     },
     {
-      "name": "Example Jobs",
-      "url": "examples"
+      "name": "Examples",
+      "url": "https://trigger.dev/apis"
     }
   ],
   "redirects": [
@@ -256,10 +254,7 @@
       "pages": [
         {
           "group": "Airtable",
-          "pages": [
-            "integrations/apis/airtable",
-            "integrations/apis/airtable-tasks"
-          ]
+          "pages": ["integrations/apis/airtable", "integrations/apis/airtable-tasks"]
         },
         {
           "group": "GitHub",
@@ -285,25 +280,16 @@
         },
         {
           "group": "Plain",
-          "pages": [
-            "integrations/apis/plain",
-            "integrations/apis/plain-tasks"
-          ]
+          "pages": ["integrations/apis/plain", "integrations/apis/plain-tasks"]
         },
         "integrations/apis/replicate",
         {
           "group": "SendGrid",
-          "pages": [
-            "integrations/apis/sendgrid",
-            "integrations/apis/sendgrid-tasks"
-          ]
+          "pages": ["integrations/apis/sendgrid", "integrations/apis/sendgrid-tasks"]
         },
         {
           "group": "Resend",
-          "pages": [
-            "integrations/apis/resend",
-            "integrations/apis/resend-tasks"
-          ]
+          "pages": ["integrations/apis/resend", "integrations/apis/resend-tasks"]
         },
         {
           "group": "Shopify",
@@ -315,10 +301,7 @@
         },
         {
           "group": "Slack",
-          "pages": [
-            "integrations/apis/slack",
-            "integrations/apis/slack-tasks"
-          ]
+          "pages": ["integrations/apis/slack", "integrations/apis/slack-tasks"]
         },
         "integrations/apis/stripe",
         {
@@ -343,9 +326,7 @@
             "sdk/triggerclient/constructor",
             {
               "group": "Instance properties",
-              "pages": [
-                "sdk/triggerclient/store"
-              ]
+              "pages": ["sdk/triggerclient/store"]
             },
             {
               "group": "Instance methods",
@@ -355,6 +336,7 @@
                 "sdk/triggerclient/instancemethods/getevent",
                 "sdk/triggerclient/instancemethods/cancel-event",
                 "sdk/triggerclient/instancemethods/cancel-runs-for-event",
+                "sdk/triggerclient/instancemethods/cancel-runs-for-job",
                 "sdk/triggerclient/instancemethods/getruns",
                 "sdk/triggerclient/instancemethods/getrun",
                 "sdk/triggerclient/instancemethods/define-job",
@@ -407,10 +389,7 @@
             "sdk/dynamictrigger/constructor",
             {
               "group": "Instance methods",
-              "pages": [
-                "sdk/dynamictrigger/register",
-                "sdk/dynamictrigger/unregister"
-              ]
+              "pages": ["sdk/dynamictrigger/register", "sdk/dynamictrigger/unregister"]
             }
           ]
         },
@@ -421,10 +400,7 @@
             "sdk/dynamicschedule/constructor",
             {
               "group": "Instance methods",
-              "pages": [
-                "sdk/dynamicschedule/register",
-                "sdk/dynamicschedule/unregister"
-              ]
+              "pages": ["sdk/dynamicschedule/register", "sdk/dynamicschedule/unregister"]
             }
           ]
         },
@@ -436,9 +412,7 @@
     },
     {
       "group": "HTTP Reference",
-      "pages": [
-        "sdk/api-reference/events/create-an-event"
-      ]
+      "pages": ["sdk/api-reference/events/create-an-event"]
     },
     {
       "group": "React SDK",
@@ -452,9 +426,7 @@
     },
     {
       "group": "Overview",
-      "pages": [
-        "examples/introduction"
-      ]
+      "pages": ["examples/introduction"]
     }
   ],
   "footerSocials": {
@@ -467,4 +439,4 @@
       "apiKey": "phc_hwYmedO564b3Ik8nhA4Csrb5SueY0EwFJWCbseGwWW"
     }
   }
-}
+}

docs/package.json

@@ -10,4 +10,4 @@
     "node": ">=18.0.0"
   },
   "packageManager": "pnpm@7.13.5"
-}
+}

docs/sdk/triggerclient/instancemethods/cancel-runs-for-job.mdx

@@ -0,0 +1,48 @@
+---
+title: "TriggerClient: cancelRunsForJob() Instance Method"
+sidebarTitle: "cancelRunsForJob()"
+description: "The `cancelRunsForJob()` instance method will cancel all job runs (yet to be executed) with the given jobId."
+---
+
+## Parameters
+
+<ResponseField name="jobId" type="string" required>
+  The job ID to cancel the job runs for. This is the `id` you set when using `client.defineJob()` or
+  `new Job()`.
+</ResponseField>
+
+## Returns
+
+<ResponseField type="object">
+  <Expandable title="properties" defaultOpen>
+    <ResponseField name="cancelledRunIds" type="array" required>
+      List of Job Run IDs that are cancelled.
+    </ResponseField>
+    <ResponseField name="failedToCancelRunIds" type="array" required>
+      List of Job Run IDs that have failed to be cancelled.
+    </ResponseField>
+  </Expandable>
+</ResponseField>
+
+<RequestExample>
+
+```ts Cancelling Runs for an Event
+//this is the job we want to cancel runs for
+client.defineJob({
+  //this is the job id
+  id: "my-job",
+  name: "My first job",
+  version: "1.0.0",
+  trigger: invokeTrigger({ schema: z.number() }),
+  run: async (payload, io, ctx) => {
+    await io.logger.info(`Hello World ${payload}`);
+  },
+});
+
+// Some time later...
+const res = await client.cancelRunsForJob("my-job");
+console.log(res.cancelledRunIds);
+console.log(res.failedToCancelRunIds);
+```
+
+</RequestExample>

docs/sdk/triggerclient/overview.mdx

@@ -60,6 +60,10 @@ The `cancelEvent()` method cancels an event that is scheduled to be delivered in
 
 The `cancelRunsForEvent()` method cancels the job runs (yet to be executed) that are triggered by a given eventId.
 
+### [cancelRunsForJob()](/sdk/triggerclient/instancemethods/cancel-runs-for-job)
+
+The `cancelRunsForJob()` method cancels all runs for the specified job (yet to be executed).
+
 ### [getRuns()](/sdk/triggerclient/instancemethods/getruns)
 
 The `getRuns()` method gets runs for a Job.

integrations/airtable/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/airtable
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/airtable/package.json

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

integrations/github/CHANGELOG.md

@@ -1,5 +1,21 @@
 # @trigger.dev/github
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- 5060eec0: Update Octokit to account for CVE-2023-50728
+  - @trigger.dev/integration-kit@2.3.8
+  - @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/github/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/github",
-  "version": "2.3.7",
+  "version": "2.3.9",
   "description": "The official GitHub integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -11,8 +11,8 @@
     "dist"
   ],
   "devDependencies": {
-    "@octokit/types": "^9.2.3",
-    "@octokit/webhooks-types": "^6.10.0",
+    "@octokit/types": "^12.4.0",
+    "@octokit/webhooks-types": "^7.3.1",
     "@trigger.dev/tsconfig": "workspace:*",
     "@types/node": "18",
     "rimraf": "^3.0.2",
@@ -26,12 +26,12 @@
     "build:tsup": "tsup"
   },
   "dependencies": {
-    "@octokit/request": "^6.2.5",
-    "@octokit/request-error": "^4.0.1",
-    "@octokit/webhooks": "^10.4.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.7",
-    "@trigger.dev/sdk": "workspace:^2.3.7",
-    "octokit": "^2.0.14",
+    "@octokit/request": "^8.1.6",
+    "@octokit/request-error": "^5.0.1",
+    "@octokit/webhooks": "^12.0.10",
+    "octokit": "^3.1.2",
+    "@trigger.dev/integration-kit": "workspace:^2.3.9",
+    "@trigger.dev/sdk": "workspace:^2.3.9",
     "zod": "3.22.3"
   },
   "engines": {

integrations/linear/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/linear
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/linear/package.json

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

integrations/openai/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/slack
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/openai/package.json

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

integrations/plain/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/plain
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/plain/package.json

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

integrations/replicate/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/replicate
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/replicate/package.json

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

integrations/resend/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/resend
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/resend/package.json

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

integrations/sendgrid/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/sendgrid
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/sendgrid/package.json

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

integrations/shopify/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/shopify
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/shopify/package.json

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

integrations/slack/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/slack
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/slack/package.json

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

integrations/stripe/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/stripe
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/stripe/package.json

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

integrations/supabase/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/supabase
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/supabase/package.json

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

integrations/typeform/CHANGELOG.md

@@ -1,5 +1,20 @@
 # @trigger.dev/typeform
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

integrations/typeform/package.json

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

packages/astro/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/astro
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### 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.7",
+  "version": "2.3.9",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "files": [
@@ -20,7 +20,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.7"
+    "@trigger.dev/sdk": "workspace:^2.3.9"
   },
   "devDependencies": {
     "astro": "^3.0.12",

packages/cli/CHANGELOG.md

@@ -1,5 +1,21 @@
 # create-trigger
 
+## 2.3.9
+
+### Patch Changes
+
+- aa97bf4a: Updated the telemetry API key
+- Updated dependencies [740b7b23]
+  - @trigger.dev/core@2.3.9
+  - @trigger.dev/yalt@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.8
+- @trigger.dev/yalt@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/cli/package.json

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

packages/cli/src/telemetry/telemetry.ts

@@ -5,7 +5,7 @@ import { getVersion } from "../utils/getVersion";
 import { DevCommandOptions } from "../commands/dev";
 import { ProjectInstallOptions } from "../frameworks";
 
-const postHogApiKey = "phc_hwYmedO564b3Ik8nhA4Csrb5SueY0EwFJWCbseGwWW";
+const postHogApiKey = "phc_9aSDbJCaDUMdZdHxxMPTvcj7A9fsl3mCgM1RBPmPsl7";
 
 export class TelemetryClient {
   #client: PostHog;
@@ -14,7 +14,7 @@ export class TelemetryClient {
 
   constructor() {
     this.#client = new PostHog(postHogApiKey, {
-      host: "https://app.posthog.com",
+      host: "https://eu.posthog.com",
       flushAt: 1,
     });
     this.#sessionId = `cli-${nanoid()}`;

packages/core-backend/CHANGELOG.md

@@ -1,5 +1,9 @@
 # @trigger.dev/core-backend
 
+## 2.3.9
+
+## 2.3.8
+
 ## 2.3.7
 
 ## 2.3.6

packages/core-backend/package.json

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

packages/core/CHANGELOG.md

@@ -1,5 +1,13 @@
 # internal-platform
 
+## 2.3.9
+
+### Patch Changes
+
+- 740b7b23: feat: Add $not to eventFilters
+
+## 2.3.8
+
 ## 2.3.7
 
 ## 2.3.6

packages/core/package.json

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

packages/core/src/eventFilterMatches.ts

@@ -198,5 +198,15 @@ function contentFilterMatches(actualValue: any, contentFilter: ContentFilters[nu
     return actualValue !== null;
   }
 
+  if ("$not" in contentFilter) {
+    if (Array.isArray(actualValue)) {
+      return !actualValue.includes(contentFilter.$not);
+    } else if (typeof actualValue === 'number' || typeof actualValue === 'boolean' || typeof actualValue === 'string') {
+      return actualValue !== contentFilter.$not;
+    }
+
+    return false;
+  }
+
   return true;
 }

packages/core/src/schemas/eventFilter.ts

@@ -52,6 +52,9 @@ const EventMatcherSchema = z.union([
       z.object({
         $includes: z.union([z.string(), z.number(), z.boolean()]),
       }),
+      z.object({
+        $not: z.union([z.string(), z.number(), z.boolean()])
+      })
     ])
   ),
 ]);

packages/core/src/schemas/index.ts

@@ -15,3 +15,4 @@ export * from "./runs";
 export * from "./addMissingVersionField";
 export * from "./statuses";
 export * from "./request";
+export * from "./jobs";

packages/core/src/schemas/jobs.ts

@@ -0,0 +1,8 @@
+import { z } from "zod";
+
+export const CancelRunsForJobSchema = z.object({
+  cancelledRunIds: z.array(z.string()),
+  failedToCancelRunIds: z.array(z.string()),
+});
+
+export type CancelRunsForJob = z.infer<typeof CancelRunsForJobSchema>;

packages/core/test/eventFilterMatches.test.ts

@@ -252,6 +252,54 @@ describe("eventFilterMatches", () => {
     expect(eventFilterMatches(payload, filter)).toBe(true);
   });
 
+  it("should return true when payload matches an not condition", () => {
+    const payload = {
+      name: "John",
+      age: 30,
+      score: 100,
+      isAdmin: false,
+      hobbies: ["reading", "swimming"],
+      address: {
+        street: "123 Main St",
+        city: "Anytown",
+        state: "CA",
+        zip: "12345",
+      },
+    };
+    const filter: EventFilter = {
+      hobbies: [{ $not: "gaming" }],
+      age: [{ $not: 39 }],
+      isAdmin: [{ $not: true }],
+      name: [{ $not: 'Test' }]
+    };
+
+    expect(eventFilterMatches(payload, filter)).toBe(true);
+  });
+
+  it("should return false when payload not matches an not condition", () => {
+    const payload = {
+      name: "John",
+      age: 30,
+      score: 100,
+      isAdmin: false,
+      hobbies: ["reading", "swimming"],
+      address: {
+        street: "123 Main St",
+        city: "Anytown",
+        state: "CA",
+        zip: "12345",
+      },
+    };
+    const filter: EventFilter = {
+      hobbies: [{ $not: "reading" }],
+      age: [{ $not: 30 }],
+      isAdmin: [{ $not: false }],
+      name: [{ $not: 'John' }]
+    };
+
+    expect(eventFilterMatches(payload, filter)).toBe(false);
+  });
+
   it("should return true when payload matches an ignoreCaseEquals condition", () => {
     const payload = {
       name: "John",

packages/eslint-plugin/CHANGELOG.md

@@ -1,5 +1,9 @@
 # @trigger.dev/eslint-plugin
 
+## 2.3.9
+
+## 2.3.8
+
 ## 2.3.7
 
 ## 2.3.6

packages/eslint-plugin/package.json

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

packages/express/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/express
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/express/package.json

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

packages/hono/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/hono
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/hono/package.json

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

packages/integration-kit/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/integration-kit
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [740b7b23]
+  - @trigger.dev/core@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/integration-kit/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/integration-kit",
-  "version": "2.3.7",
+  "version": "2.3.9",
   "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,18 @@
 # @trigger.dev/nestjs
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/nestjs/package.json

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

packages/nextjs/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/nextjs
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/nextjs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/nextjs",
-  "version": "2.3.7",
+  "version": "2.3.9",
   "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.7",
+    "@trigger.dev/sdk": "workspace:^2.3.9",
     "next": ">=12.0.0"
   },
   "dependencies": {

packages/react/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/react
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [740b7b23]
+  - @trigger.dev/core@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/react/package.json

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

packages/remix/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/remix
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/remix/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/remix",
-  "version": "2.3.7",
+  "version": "2.3.9",
   "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.7",
+    "@trigger.dev/sdk": "workspace:^2.3.9",
     "@remix-run/server-runtime": ">1.19.0"
   },
   "dependencies": {

packages/sveltekit/CHANGELOG.md

@@ -1,5 +1,18 @@
 # @trigger.dev/sveltekit
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/sveltekit/package.json

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

packages/testing/CHANGELOG.md

@@ -1,5 +1,21 @@
 # @trigger.dev/testing
 
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [740b7b23]
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/core@2.3.9
+  - @trigger.dev/sdk@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.8
+- @trigger.dev/sdk@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/testing/package.json

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

packages/trigger-sdk/CHANGELOG.md

@@ -1,5 +1,21 @@
 # @trigger.dev/sdk
 
+## 2.3.9
+
+### Patch Changes
+
+- f7bf25f0: feat: Add ability to cancel all runs for job from SDK
+- Updated dependencies [740b7b23]
+  - @trigger.dev/core@2.3.9
+  - @trigger.dev/core-backend@2.3.9
+
+## 2.3.8
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.8
+- @trigger.dev/core-backend@2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/trigger-sdk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sdk",
-  "version": "2.3.7",
+  "version": "2.3.9",
   "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.7",
-    "@trigger.dev/core-backend": "workspace:^2.3.7",
+    "@trigger.dev/core": "workspace:^2.3.9",
+    "@trigger.dev/core-backend": "workspace:^2.3.9",
     "chalk": "^5.2.0",
     "cronstrue": "^2.21.0",
     "debug": "^4.3.4",

packages/trigger-sdk/src/apiClient.ts

@@ -3,6 +3,7 @@ import {
   ApiEventLog,
   ApiEventLogSchema,
   CancelRunsForEventSchema,
+  CancelRunsForJobSchema,
   CompleteTaskBodyV2Input,
   ConnectionAuthSchema,
   EphemeralEventDispatcherRequestBody,
@@ -553,6 +554,26 @@ export class ApiClient {
     });
   }
 
+  async cancelRunsForJob(jobId: string) {
+    const apiKey = await this.#apiKey();
+
+    this.#logger.debug("Cancelling Runs for Job", {
+      jobId,
+    });
+
+    return await zodfetch(
+      CancelRunsForJobSchema,
+      `${this.#apiUrl}/api/v1/jobs/${jobId}/cancel-runs`,
+      {
+        method: "POST",
+        headers: {
+          "Content-Type": "application/json",
+          Authorization: `Bearer ${apiKey}`,
+        },
+      }
+    );
+  }
+
   async createEphemeralEventDispatcher(payload: EphemeralEventDispatcherRequestBody) {
     const apiKey = await this.#apiKey();
 

packages/trigger-sdk/src/triggerClient.ts

@@ -1065,6 +1065,10 @@ export class TriggerClient {
     return this.#client.invokeJob(jobId, payload, options);
   }
 
+  async cancelRunsForJob(jobId: string) {
+    return this.#client.cancelRunsForJob(jobId);
+  }
+
   async createEphemeralEventDispatcher(payload: EphemeralEventDispatcherRequestBody) {
     return this.#client.createEphemeralEventDispatcher(payload);
   }
@@ -1684,15 +1688,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) {
@@ -1709,8 +1713,9 @@ 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)}`,
       };
     }
   }
@@ -1737,8 +1742,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/yalt/CHANGELOG.md

@@ -1,5 +1,9 @@
 # @trigger.dev/yalt
 
+## 2.3.9
+
+## 2.3.8
+
 ## 2.3.7
 
 ### Patch Changes

packages/yalt/package.json

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