Skip to content

Commit bc75afc

Browse files
committed
Increase retry interval for protos registration, update logging
1 parent c7d1215 commit bc75afc

File tree

1 file changed

+11
-6
lines changed
  • framework/components/dockercompose/chip_ingress_set

1 file changed

+11
-6
lines changed

framework/components/dockercompose/chip_ingress_set/protos.go

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ func checkSchemaExists(registryURL, subject string) (int, bool) {
560560
var err error
561561
resp, err = http.Get(url)
562562
if err != nil {
563-
framework.L.Debug().Msgf("Failed to check schema existence for %s: %v", subject, err)
563+
framework.L.Error().Msgf("Failed to check schema existence for %s: %v", subject, err)
564564
return err
565565
}
566566

@@ -569,13 +569,18 @@ func checkSchemaExists(registryURL, subject string) (int, bool) {
569569
}
570570

571571
return nil
572-
}, retry.Attempts(10), retry.Delay(100*time.Millisecond), retry.DelayType(retry.BackOffDelay), retry.OnRetry(func(n uint, err error) {
573-
framework.L.Debug().Str("attempt/max", fmt.Sprintf("%d/%d", n, maxAttempts)).Msgf("Retrying to check schema existence for %s: %v", subject, err)
574-
}), retry.RetryIf(func(err error) bool {
575-
return isRetryableError(err)
576-
}))
572+
}, retry.Attempts(10),
573+
retry.Delay(500*time.Millisecond),
574+
retry.DelayType(retry.BackOffDelay),
575+
retry.OnRetry(func(n uint, err error) {
576+
framework.L.Warn().Str("attempt/max", fmt.Sprintf("%d/%d", n, maxAttempts)).Msgf("Retrying to check schema existence for %s: %v", subject, err)
577+
}),
578+
retry.RetryIf(func(err error) bool {
579+
return isRetryableError(err)
580+
}))
577581

578582
if existErr != nil {
583+
framework.L.Warn().Str("subject", subject).Err(existErr).Msgf("All %d attempts to check schema existence failed. Last error: %v", maxAttempts, existErr)
579584
return 0, false
580585
}
581586

0 commit comments

Comments
 (0)