Skip to content

Commit 0359a7e

Browse files
committed
Fix error message for relay
1 parent 4e5d30e commit 0359a7e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

enterprise/replicasync/replicasync.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ func (m *Manager) subscribe(ctx context.Context) error {
178178
update = func() {
179179
err := m.syncReplicas(ctx)
180180
if err != nil && !errors.Is(err, context.Canceled) {
181-
m.logger.Error(ctx, "run replica from subscribe", slog.Error(err))
181+
m.logger.Warn(ctx, "run replica from subscribe", slog.Error(err))
182182
}
183183
updateMutex.Lock()
184184
if needsUpdate {
@@ -256,7 +256,7 @@ func (m *Manager) syncReplicas(ctx context.Context) error {
256256
defer wg.Done()
257257
req, err := http.NewRequestWithContext(ctx, http.MethodGet, peer.RelayAddress, nil)
258258
if err != nil {
259-
m.logger.Error(ctx, "create http request for relay probe",
259+
m.logger.Warn(ctx, "create http request for relay probe",
260260
slog.F("relay_address", peer.RelayAddress), slog.Error(err))
261261
return
262262
}

0 commit comments

Comments
 (0)