|
4 | 4 | "context" |
5 | 5 | "time" |
6 | 6 |
|
7 | | - "go.uber.org/zap" |
8 | | - |
9 | 7 | "go.temporal.io/sdk/workflow" |
10 | 8 | ) |
11 | 9 |
|
@@ -44,39 +42,39 @@ func BasicSagaWorkflow(ctx workflow.Context, initialAmount int) (int, error) { |
44 | 42 |
|
45 | 43 | err = workflow.ExecuteActivity(ctx, ca.Add, currentAmount, 10).Get(ctx, ¤tAmount) |
46 | 44 | if err != nil { |
47 | | - logger.Error("activity failed", zap.Error(err)) |
| 45 | + logger.Error("activity failed", "error", err) |
48 | 46 | handleSagaErr(ctx, Compensate(sagaCtx)) |
49 | 47 | return 0, err |
50 | 48 | } |
51 | 49 | AddCompensation(sagaCtx, func(ctx workflow.Context) error { |
52 | 50 | compensationOrder = append(compensationOrder, 5) |
53 | 51 | err := workflow.ExecuteActivity(ctx, ca.Minus, currentAmount, 5).Get(ctx, ¤tAmount) |
54 | 52 | if err != nil { |
55 | | - logger.Error("compensation activity failed", zap.Error(err)) |
| 53 | + logger.Error("compensation activity failed", "error", err) |
56 | 54 | return err |
57 | 55 | } |
58 | 56 | return nil |
59 | 57 | }) |
60 | 58 |
|
61 | 59 | err = workflow.ExecuteActivity(ctx, ca.Add, currentAmount, 20).Get(ctx, ¤tAmount) |
62 | 60 | if err != nil { |
63 | | - logger.Error("activity failed", zap.Error(err)) |
| 61 | + logger.Error("activity failed", "error", err) |
64 | 62 | handleSagaErr(ctx, Compensate(sagaCtx)) |
65 | 63 | return 0, err |
66 | 64 | } |
67 | 65 | AddCompensation(sagaCtx, func(ctx workflow.Context) error { |
68 | 66 | compensationOrder = append(compensationOrder, 10) |
69 | 67 | err := workflow.ExecuteActivity(ctx, ca.Minus, currentAmount, 10).Get(ctx, ¤tAmount) |
70 | 68 | if err != nil { |
71 | | - logger.Error("compensation activity failed", zap.Error(err)) |
| 69 | + logger.Error("compensation activity failed", "error", err) |
72 | 70 | return err |
73 | 71 | } |
74 | 72 | return nil |
75 | 73 | }) |
76 | 74 |
|
77 | 75 | err = workflow.ExecuteActivity(ctx, ca.Add, currentAmount, 30).Get(ctx, ¤tAmount) |
78 | 76 | if err != nil { |
79 | | - logger.Error("activity failed", zap.Error(err)) |
| 77 | + logger.Error("activity failed", "error", err) |
80 | 78 | handleSagaErr(ctx, Compensate(sagaCtx)) |
81 | 79 | return 0, err |
82 | 80 | } |
@@ -111,14 +109,14 @@ func MultipleCompensateSagaWorkflow(ctx workflow.Context, initialAmount int) (in |
111 | 109 |
|
112 | 110 | err = workflow.ExecuteActivity(ctx, ca.Add, currentAmount, 10).Get(ctx, ¤tAmount) |
113 | 111 | if err != nil { |
114 | | - logger.Error("activity failed", zap.Error(err)) |
| 112 | + logger.Error("activity failed", "error", err) |
115 | 113 | handleSagaErr(ctx, Compensate(sagaCtx)) |
116 | 114 | return 0, err |
117 | 115 | } |
118 | 116 | AddCompensation(sagaCtx, func(ctx workflow.Context) error { |
119 | 117 | err := workflow.ExecuteActivity(ctx, ca.Minus, currentAmount, 5).Get(ctx, ¤tAmount) |
120 | 118 | if err != nil { |
121 | | - logger.Error("compensation activity failed", zap.Error(err)) |
| 119 | + logger.Error("compensation activity failed", "error", err) |
122 | 120 | return err |
123 | 121 | } |
124 | 122 | return nil |
|
0 commit comments