diff --git a/pkg/runtime/runtime.go b/pkg/runtime/runtime.go
index 41b468c68..3c441a0ee 100644
--- a/pkg/runtime/runtime.go
+++ b/pkg/runtime/runtime.go
@@ -55,7 +55,7 @@ func (r *Runtime) Start() error {
 	defer cancel()
 
 	g, gCtx := errgroup.WithContext(ctx)
-	dataSync := make(chan sync.DataSync)
+	dataSync := make(chan sync.DataSync, len(r.SyncImpl))
 
 	// Initialize DataSync channel watcher
 	g.Go(func() error {