diff --git a/pkg/flow/circuitbreaker_flow.go b/pkg/flow/circuitbreaker_flow.go index 1c20a59b..a0b5a284 100644 --- a/pkg/flow/circuitbreaker_flow.go +++ b/pkg/flow/circuitbreaker_flow.go @@ -151,7 +151,7 @@ func (df *DefaultFunctionalDecorator) Decorator(ctx context.Context, args interf Duration: delay, Result: ret, } - invoke.OnError(rspCtx) + invoke.OnSuccess(rspCtx) } }()