retries-worker.ts

import Hatchet, { Workflow } from '@hatchet-dev/typescript-sdk';

const hatchet = Hatchet.init();

const sleep = (ms: number) =>
  new Promise((resolve) => {
    setTimeout(resolve, ms);
  });

let numRetries = 0;

const workflow: Workflow = {
  id: 'retries-workflow',
  description: 'test',
  on: {
    event: 'user:create',
  },
  steps: [
    {
      name: 'step1',
      run: async (ctx) => {
        if (numRetries < 3) {
          numRetries += 1;
          throw new Error('step1 failed');
        }

        console.log(
          'starting step1 with the following input',
          ctx.workflowInput(),
        );
        console.log('waiting 5 seconds...');
        await sleep(5000);
        console.log('executed step1!');
        return { step1: 'step1 results!' };
      },
      retries: 3,
    },
    {
      name: 'step2',
      parents: ['step1'],
      run: (ctx) => {
        console.log(
          'executed step2 after step1 returned ',
          ctx.stepOutput('step1'),
        );
        return { step2: 'step2 results!' };
      },
    },
  ],
};

async function main() {
  const worker = await hatchet.worker('example-worker');
  await worker.registerWorkflow(workflow);
  worker.start();
}

main();