From bc75afc794f1c71c79659b8461a1ab9ed162afa8 Mon Sep 17 00:00:00 2001 From: Alexandr Yepishev Date: Mon, 6 Oct 2025 17:01:24 +0100 Subject: [PATCH] Increase retry interval for protos registration, update logging --- .../dockercompose/chip_ingress_set/protos.go | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/framework/components/dockercompose/chip_ingress_set/protos.go b/framework/components/dockercompose/chip_ingress_set/protos.go index eaa8c657d..29e8f361d 100644 --- a/framework/components/dockercompose/chip_ingress_set/protos.go +++ b/framework/components/dockercompose/chip_ingress_set/protos.go @@ -560,7 +560,7 @@ func checkSchemaExists(registryURL, subject string) (int, bool) { var err error resp, err = http.Get(url) if err != nil { - framework.L.Debug().Msgf("Failed to check schema existence for %s: %v", subject, err) + framework.L.Error().Msgf("Failed to check schema existence for %s: %v", subject, err) return err } @@ -569,13 +569,18 @@ func checkSchemaExists(registryURL, subject string) (int, bool) { } return nil - }, retry.Attempts(10), retry.Delay(100*time.Millisecond), retry.DelayType(retry.BackOffDelay), retry.OnRetry(func(n uint, err error) { - framework.L.Debug().Str("attempt/max", fmt.Sprintf("%d/%d", n, maxAttempts)).Msgf("Retrying to check schema existence for %s: %v", subject, err) - }), retry.RetryIf(func(err error) bool { - return isRetryableError(err) - })) + }, retry.Attempts(10), + retry.Delay(500*time.Millisecond), + retry.DelayType(retry.BackOffDelay), + retry.OnRetry(func(n uint, err error) { + framework.L.Warn().Str("attempt/max", fmt.Sprintf("%d/%d", n, maxAttempts)).Msgf("Retrying to check schema existence for %s: %v", subject, err) + }), + retry.RetryIf(func(err error) bool { + return isRetryableError(err) + })) if existErr != nil { + framework.L.Warn().Str("subject", subject).Err(existErr).Msgf("All %d attempts to check schema existence failed. Last error: %v", maxAttempts, existErr) return 0, false }