Capturing Failures

const step = thread.step('payment_processed');

try {
  const payment = await processPayment(orderId);
  await step.addContext(payment).success();
} catch (error) {
  await step.failed({ 
    message: error.message,
    errorCode: 'PAYMENT_FAILED',
    retryable: true
  });
}

paymentStep := thread.Step("payment_processed")
payment, err := processPayment(orderId)
if err != nil {
    _, stepErr := paymentStep.Failed(ctx, map[string]any{
        "message":   err.Error(),
        "errorCode": "PAYMENT_FAILED",
        "retryable": true,
    })
    if stepErr != nil {
        log.Fatal(stepErr)
    }
    return
}
_, err = paymentStep.AddContext(payment).Success(ctx)
if err != nil {
    log.Fatal(err)
}

payment_step = thread.step("payment_processed")
try:
    payment = await process_payment(order_id)
    await payment_step.add_context(payment).success()
except Exception as error:
    await payment_step.failed({
        "message": str(error),
        "errorCode": "PAYMENT_FAILED",
        "retryable": True
    })