diff --git a/backend/pkg/monitoring/monitoring.go b/backend/pkg/monitoring/monitoring.go
index b24c3cb9a..dbf021a77 100644
--- a/backend/pkg/monitoring/monitoring.go
+++ b/backend/pkg/monitoring/monitoring.go
@@ -1,6 +1,9 @@
 package monitoring
 
 import (
+	"sync"
+	"sync/atomic"
+
 	"github.com/gobitfly/beaconchain/pkg/commons/db"
 	"github.com/gobitfly/beaconchain/pkg/commons/log"
 	"github.com/gobitfly/beaconchain/pkg/commons/metrics"
@@ -11,11 +14,17 @@ import (
 )
 
 var monitoredServices []services.Service
+var startedClickhouse atomic.Bool
+var initMutex = sync.Mutex{}
 
 func Init(full bool) {
+	initMutex.Lock()
+	defer initMutex.Unlock()
 	metrics.UUID.WithLabelValues(utils.GetUUID()).Set(1) // so we can find out where the uuid is set
 	metrics.DeploymentType.WithLabelValues(utils.Config.DeploymentType).Set(1)
 	if db.ClickHouseNativeWriter == nil {
+		log.Infof("initializing clickhouse writer")
+		startedClickhouse.Store(true)
 		db.ClickHouseNativeWriter = db.MustInitClickhouseNative(&types.DatabaseConfig{
 			Username:     utils.Config.ClickHouse.WriterDatabase.Username,
 			Password:     utils.Config.ClickHouse.WriterDatabase.Password,
@@ -58,4 +67,7 @@ func Stop() {
 	}
 	// this prevents status reports that werent shut down cleanly from triggering alerts
 	services.NewStatusReport(constants.CleanShutdownEvent, constants.Default, constants.Default)(constants.Success, nil)
+	if startedClickhouse.Load() {
+		db.ClickHouseNativeWriter.Close()
+	}
 }