index.ts

import { task } from '@renderinc/sdk/workflows'

// A minimal task definition
const calculateSquare = task(
  { name: 'calculateSquare' },
  function calculateSquare(a: number): number {
    return a * a
  }
)

// A task that chains two parallel runs
const sumSquares = task(
  { name: 'sumSquares' },
  async function sumSquares(a: number, b: number): Promise<number> {
    const [result1, result2] = await Promise.all([
      calculateSquare(a),
      calculateSquare(b)
    ])
    return result1 + result2
  }
)

// A task that flips a coin and retries on "tails"
// (Illustrates specifying retry logic on failure)
const flipCoin = task(
  {
    name: 'flipCoin',
    retry: {
      maxRetries: 3,
      waitDurationMs: 1000,
      backoffScaling: 1.5
    }
  },
  function flipCoin(): string {
    if (Math.random() < 0.5) {
      throw new Error('Flipped tails! Retrying.')
    }
    return 'Flipped heads!'
  }
)