Cadence

func SubscriptionWorkflow(ctx workflow.Context, id string) error { ctx = workflow.WithActivityOptions(ctx, opts) // Cadence retries this activity for you. err := workflow.ExecuteActivity(ctx, Charge, id).Get(ctx, nil) if err != nil { return err } // Durable sleep: survives worker restarts. workflow.Sleep(ctx, 30*24*time.Hour) return workflow.ExecuteActivity(ctx, Renew, id).Get(ctx, nil)}