Real-World Examples

await stackshift.queue('emails').enqueue(
  'sendVerificationEmail',
  { userId: 'user_123', email: 'ada@example.com' },
  { idempotencyKey: 'verify:user_123' }
)

stackshift.job<{ paymentId: string; customerId: string }>('provisionAfterPayment', async ({ payload, step }) => {
  const payment = await step.run('verify-payment', () => verifyPayment(payload.paymentId))

  if (payment.status !== "paid") {
    throw new Error('Payment is not complete')
  }

  await step.run('provision-customer-resources', () => provisionCustomerResources(payload.customerId))
  await step.run('enable-plan', () => enablePaidPlan(payload.customerId))
  await step.run('send-receipt', () => sendReceipt(payment.customerEmail))

  return { provisioned: true }
})

stackshift.job<{ fileId: string }>('processUpload', async ({ payload, step, state }) => {
  const file = await step.run('download-file', () => downloadFile(payload.fileId))
  const parsed = await step.run('parse-file', () => parseCsv(file))

  for (const batch of parsed.batches) {
    await importRows(batch)
    await state.increment(`files:${payload.fileId}:rows`, batch.length)
  }

  await step.run('mark-complete', () => markFileComplete(payload.fileId))

  return { rows: parsed.totalRows }
})