Skip to content

Commit afed053

Browse files
committed
Add more visibility in CI for beholder protos registration with updated logging
1 parent c7d1215 commit afed053

File tree

1 file changed

+3
-2
lines changed
  • framework/components/dockercompose/chip_ingress_set

1 file changed

+3
-2
lines changed

framework/components/dockercompose/chip_ingress_set/protos.go

Lines changed: 3 additions & 2 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

@@ -570,12 +570,13 @@ func checkSchemaExists(registryURL, subject string) (int, bool) {
570570

571571
return nil
572572
}, 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)
573+
framework.L.Warn().Str("attempt/max", fmt.Sprintf("%d/%d", n, maxAttempts)).Msgf("Retrying to check schema existence for %s: %v", subject, err)
574574
}), retry.RetryIf(func(err error) bool {
575575
return isRetryableError(err)
576576
}))
577577

578578
if existErr != nil {
579+
framework.L.Warn().Str("subject", subject).Err(existErr).Msgf("All %d attempts to check schema existence failed. Last error: %v", maxAttempts, existErr)
579580
return 0, false
580581
}
581582

0 commit comments

Comments
 (0)