diff --git a/internal/persistence/database.go b/internal/persistence/database.go index 2b21b8d..7da955d 100644 --- a/internal/persistence/database.go +++ b/internal/persistence/database.go @@ -121,11 +121,14 @@ func NewDBStore(clusterID uint, fleetName string, log *zap.Logger, options ...DB } } - result.db.Exec("update missingMessages set fleet = 'status.prod'") + _, err := result.db.Exec("update missingMessages set fleet = 'status.prod'") + log.Info("RESULT", zap.Error(err)) result.db.Exec("update storeNodeUnavailable set fleet = 'status.prod'") + log.Info("RESULT", zap.Error(err)) result.db.Exec("update syncTopicStatus set fleet = 'status.prod'") + log.Info("RESULT", zap.Error(err)) return result, nil }