fix: rollback dal checkers

Bisonai · Aug 22, 2024 · e0ff429 · e0ff429
1 parent f9c0ed5
commit e0ff429
Showing 1 changed file with 25 additions and 25 deletions.
diff --git a/node/cmd/sentinel/main.go b/node/cmd/sentinel/main.go
@@ -7,8 +7,8 @@ import (
 	"sync"
 
 	"bisonai.com/miko/node/pkg/checker/balance"
-	// "bisonai.com/miko/node/pkg/checker/dal"
-	// "bisonai.com/miko/node/pkg/checker/dalstats"
+	"bisonai.com/miko/node/pkg/checker/dal"
+	"bisonai.com/miko/node/pkg/checker/dalstats"
 	"bisonai.com/miko/node/pkg/checker/dbcronjob"
 	"bisonai.com/miko/node/pkg/checker/event"
 	"bisonai.com/miko/node/pkg/checker/health"
@@ -111,29 +111,29 @@ func main() {
 
 	log.Info().Msg("peers checker started")
 
-	// wg.Add(1)
-	// go func() {
-	// 	defer wg.Done()
-	// 	err := dal.Start(ctx)
-	// 	if err != nil {
-	// 		log.Error().Err(err).Msg("error starting dal checker")
-	// 		os.Exit(1)
-	// 	}
-	// }()
-
-	// log.Info().Msg("dal checker started")
-
-	// wg.Add(1)
-	// go func() {
-	// 	defer wg.Done()
-	// 	err := dalstats.Start(ctx)
-	// 	if err != nil {
-	// 		log.Error().Err(err).Msg("error starting dalstats checker")
-	// 		os.Exit(1)
-	// 	}
-	// }()
-
-	// log.Info().Msg("dal stats checker started")
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		err := dal.Start(ctx)
+		if err != nil {
+			log.Error().Err(err).Msg("error starting dal checker")
+			os.Exit(1)
+		}
+	}()
+
+	log.Info().Msg("dal checker started")
+
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		err := dalstats.Start(ctx)
+		if err != nil {
+			log.Error().Err(err).Msg("error starting dalstats checker")
+			os.Exit(1)
+		}
+	}()
+
+	log.Info().Msg("dal stats checker started")
 
 	wg.Add(1)
 	go func() {