Skip to content

Commit 28f6fc0

Browse files
committed
只要有一个错误就立刻返回,避免所以错误都抛出来干扰 开发者的判断。
1 parent 31670c0 commit 28f6fc0

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

pkg/flow/sync_flow.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -159,11 +159,13 @@ outLoop:
159159
sdkErrs := syncCtx.Errs()
160160
if len(sdkErrs) > 0 {
161161
e.reportCombinedErrs(req.GetCallResult(), consumedTime, sdkErrs)
162-
rawErr := combineSDKErrors(sdkErrs)
163-
log.GetBaseLogger().Errorf("error occur while processing GetInstances request,"+
164-
" serviceKey: %s, time consume is %v, error is %s", *dstService, consumedTime, rawErr)
165-
return model.NewSDKError(model.ErrCodeServerUserError, rawErr,
166-
fmt.Sprintf("multierrs received for GetInstances request, serviceKey: %s", *dstService))
162+
// 只要有一个错误就立刻返回,避免所以错误都抛出来干扰 开发者的判断。
163+
for key, sdkErr := range sdkErrs {
164+
log.GetBaseLogger().Errorf("error occur while processing GetInstances request,"+
165+
" serviceKey: %s, time consume is %v, error is %s", *dstService, consumedTime, sdkErr)
166+
return model.NewSDKError(model.ErrCodeServerUserError, sdkErr,
167+
fmt.Sprintf("SDKError for %s, detail is %s", key, sdkErr))
168+
}
167169
}
168170
if exceedTimeout {
169171
// 只有网络错误才可以重试

0 commit comments

Comments
 (0)