Using Queues

await stackshift.queue('emails').enqueue(
  'sendReceipt',
  { orderId: 'order_123', customerId: 'cus_123' },
  {
    idempotencyKey: 'receipt:order_123',
    maxAttempts: 5,
  }
)

_, err := client.Queue("emails").Enqueue(ctx,
  "sendReceipt",
  map[string]any{"orderId": "order_123", "customerId": "cus_123"},
  &stackshift.EnqueueOptions{
    IdempotencyKey: "receipt:order_123",
    MaxAttempts: 5,
  },
)

stackshift.job<{ orderId: string; customerId: string }>('sendReceipt', async ({ payload, step }) => {
  const order = await step.run('load-order', () => loadOrder(payload.orderId))
  await step.run('send-receipt-email', () => sendReceiptEmail(order))

  return { sent: true }
})

client.Job("sendReceipt", func(ctx context.Context, job stackshift.JobContext) (any, error) {
  var payload struct {
    OrderID string `json:"orderId"`
    CustomerID string `json:"customerId"`
  }
  _ = json.Unmarshal(job.Payload, &payload)

  order, err := job.Step.Run(ctx, "load-order", func(context.Context, stackshift.HandlerInvocation) (any, error) {
    return loadOrder(payload.OrderID)
  })
  if err != nil { return nil, err }

  _, err = job.Step.Run(ctx, "send-receipt-email", func(context.Context, stackshift.HandlerInvocation) (any, error) {
    return nil, sendReceiptEmail(order)
  })
  if err != nil { return nil, err }

  return map[string]any{"sent": true}, nil
})