Trigger.dev

import { task, wait } from "@trigger.dev/sdk";

export const sendWelcomeTask = task({
  id: "send-welcome",
  retry: { maxAttempts: 5, factor: 2, minTimeoutInMs: 1000, maxTimeoutInMs: 60_000 },
  machine: "small-1x",
  maxDuration: 300,
  run: async (payload: { userId: string }) => {
    const user = await db.users.find(payload.userId);
    await wait.for({ minutes: 10 });
    await sendEmail(user.email);
  },
  onFailure: async ({ error }) => {
    await alertTeam(error);
  },
});

Define the Trigger.dev task "send-welcome" as send welcome task (up to 5 attempts; waiting 1 second to 1 minute between attempts, growing 2× each time; on a small-1x machine; stopped after 5 minutes):
  Find DB's users (payload's user ID), and call the result user.
  Wait 10 minutes.
  Send email (user's email).
  When the run fails after its last attempt:
    Alert team (error).

import { schedules } from "@trigger.dev/sdk";

export const pushMeters = schedules.task({
  id: "push-hourly-meters",
  cron: { pattern: "10 * * * *", timezone: "Europe/London", environments: ["PRODUCTION"] },
  run: async (payload) => pushMeterReadings(payload.timestamp),
});

Define the scheduled task "push-hourly-meters" as push meters, run every hour at minute 10 (cron 10 * * * *) (only in PRODUCTION):
  Push meter readings (payload's timestamp), and give back the result.

import { tasks } from "@trigger.dev/sdk";
import type { sendWelcomeTask } from "./trigger/welcome";

await sendWelcomeTask.trigger(
  { userId: user.id },
  { idempotencyKey: `welcome:${user.id}`, delay: "1h", tags: ["onboarding"] },
);

const report = await buildReportTask.triggerAndWait({ orgId }).unwrap();

await tasks.trigger<typeof sendWelcomeTask>("send-welcome", { userId: user.id });

Queue a background run of send welcome task with the payload user ID: user's ID:
  • at most once per idempotency key "welcome:{user's ID}"
  • starting after 1 hour
  • tagged "onboarding"

Start build report task and wait for its output (failing if the run failed), passing the payload org ID, and call the result report.
Queue a background run of the task "send-welcome" with the payload user ID: user's ID.