Quickstart - Duraton

You define workflows in your own code and run them in a worker you host. The worker connects to your project and runs each step; your project keeps every run’s state, so a run survives a worker restart. You need a project with Workflows on, a worker key (dtn_wk_) for the worker and a secret key (dtn_sk_) to send events.

1. Install the SDK

npm install @duraton/sdk

2. Define a workflow

A workflow is a handler made of named steps. A step that finished is never run again: after a restart the run carries on from the next one.

import { defineWorkflow } from "@duraton/sdk";

export const welcome = defineWorkflow<{ email: string }>({
  name: "welcome-email",
  triggers: [{ event: "user/signed-up" }],
  handler: async ({ event, step }) => {
    await step.run("send-welcome", () => ({ to: event.data.email }));
    await step.sleep("wait-a-day", "1d");
    await step.run("send-tips", () => ({ to: event.data.email }));
  },
});

Two more steps cover a stage you leave out and a resource you wait on:

Step	What it does
`step.skip(id, reason?)`	Records the step as `skipped`, with the reason, without running anything
`step.poll(id, probe, { every, timeout, until? })`	Runs `probe` as a step every `every` until it returns a value that is not `null` or `undefined` and that `until` (when given) accepts, then returns it. Each check is a step `<id>:probe:<n>` and each wait between checks a step `<id>:gap:<n>`. With no ready value within `timeout` it throws `PollTimeoutError`, a `NonRetriableError`

3. Connect a worker

import { connect } from "@duraton/sdk";
import { welcome } from "./workflows";

const worker = connect({
  url: "https://<slug>.<project-domain>/workflows/v1",
  apiKey: process.env.DURATON_WORKER_KEY ?? "",
  app: "shop",
  workflows: [welcome],
});

await worker.ready;
process.on("SIGTERM", () => worker.close());

ready settles once your project has the worker’s workflows. close() stops taking new steps and lets the ones in flight finish. See Workers for builds, reconnects and concurrency.

4. Send an event

import { createClient } from "@duraton/sdk/client";

const client = createClient({
  url: "https://<slug>.<project-domain>/workflows/v1",
  apiKey: "dtn_sk_...",
});

const result = await client.events.send({
  name: "user/signed-up",
  data: { email: "ana@example.test" },
});

Every workflow the event triggers starts a run. Follow it with client.runs.list({ workflow: "welcome-email" }) or live, as the reference shows.

Next

Events: names, platform events and delivery.
Schedules: start a workflow on a cron expression.
Wait tokens: pause a run until someone answers.
Limits: what a project may run at once.
MCP tools: manage workflows from an AI assistant.