update error logs

f0ssel · f0ssel · commit 71076ee54944 · 2023-11-28T14:00:02.000Z
diff --git a/enterprise/replicasync/replicasync.go b/enterprise/replicasync/replicasync.go
@@ -171,7 +171,7 @@ func (m *Manager) loop(ctx context.Context) {
 		}
 		err := m.syncReplicas(ctx)
 		if err != nil && !errors.Is(err, context.Canceled) {
-			m.logger.Warn(ctx, "run replica update loop", slog.Error(err))
+			m.logger.Error(ctx, "run replica update loop", slog.Error(err))
 		}
 	}
 }
@@ -192,7 +192,7 @@ func (m *Manager) subscribe(ctx context.Context) error {
 	update = func() {
 		err := m.syncReplicas(ctx)
 		if err != nil && !errors.Is(err, context.Canceled) {
-			m.logger.Warn(ctx, "run replica from subscribe", slog.Error(err))
+			m.logger.Error(ctx, "run replica from subscribe", slog.Error(err))
 		}
 		updateMutex.Lock()
 		if needsUpdate {

Original file line number	Diff line number	Diff line change
`@@ -171,7 +171,7 @@ func (m *Manager) loop(ctx context.Context) {`
`171`	`171`	`}`
`172`	`172`	`err := m.syncReplicas(ctx)`
`173`	`173`	`if err != nil && !errors.Is(err, context.Canceled) {`
`174`		`- m.logger.Warn(ctx, "run replica update loop", slog.Error(err))`
	`174`	`+ m.logger.Error(ctx, "run replica update loop", slog.Error(err))`
`175`	`175`	`}`
`176`	`176`	`}`
`177`	`177`	`}`
`@@ -192,7 +192,7 @@ func (m *Manager) subscribe(ctx context.Context) error {`
`192`	`192`	`update = func() {`
`193`	`193`	`err := m.syncReplicas(ctx)`
`194`	`194`	`if err != nil && !errors.Is(err, context.Canceled) {`
`195`		`- m.logger.Warn(ctx, "run replica from subscribe", slog.Error(err))`
	`195`	`+ m.logger.Error(ctx, "run replica from subscribe", slog.Error(err))`
`196`	`196`	`}`
`197`	`197`	`updateMutex.Lock()`
`198`	`198`	`if needsUpdate {`