diff --git a/internal/services/configstore/readdb/readdb.go b/internal/services/configstore/readdb/readdb.go
index 005c3a7..ad29925 100644
--- a/internal/services/configstore/readdb/readdb.go
+++ b/internal/services/configstore/readdb/readdb.go
@@ -424,7 +424,6 @@ func (r *ReadDB) Run(ctx context.Context) error {
 	}
 	r.SetInitialized(true)
 
-	errCh := make(chan error)
 	for {
 		for {
 			initialized := r.IsInitialized()
@@ -441,6 +440,7 @@ func (r *ReadDB) Run(ctx context.Context) error {
 			time.Sleep(1 * time.Second)
 		}
 
+		errCh := make(chan error, 1)
 		ctx, cancel := context.WithCancel(ctx)
 		wg := &sync.WaitGroup{}
 
diff --git a/internal/services/runservice/readdb/readdb.go b/internal/services/runservice/readdb/readdb.go
index 1974cd6..405410c 100644
--- a/internal/services/runservice/readdb/readdb.go
+++ b/internal/services/runservice/readdb/readdb.go
@@ -274,7 +274,6 @@ func (r *ReadDB) Run(ctx context.Context) error {
 	}
 	r.SetInitialized(true)
 
-	errCh := make(chan error)
 	for {
 		for {
 			initialized := r.IsInitialized()
@@ -291,6 +290,7 @@ func (r *ReadDB) Run(ctx context.Context) error {
 			time.Sleep(1 * time.Second)
 		}
 
+		errCh := make(chan error, 2)
 		ctx, cancel := context.WithCancel(ctx)
 		wg := &sync.WaitGroup{}