fix(manager): full-node syncing fix (#1013)

block/manager.go

@@ -146,9 +146,10 @@ func (m *Manager) Start(ctx context.Context) error {
 		}
 	}
 
-	eg, ctx := errgroup.WithContext(ctx)
-
 	if isSequencer {
+
+		eg, ctx := errgroup.WithContext(ctx)
+
 		// Sequencer must wait till DA is synced to start submitting blobs
 		<-m.DAClient.Synced()
 		nBytes := m.GetUnsubmittedBytes()
@@ -164,6 +165,10 @@ func (m *Manager) Start(ctx context.Context) error {
 			bytesProducedC <- nBytes
 			return m.ProduceBlockLoop(ctx, bytesProducedC)
 		})
+		go func() {
+			_ = eg.Wait() // errors are already logged
+			m.logger.Info("Block manager err group finished.")
+		}()
 
 	} else {
 		// Full-nodes can sync from DA but it is not necessary to wait for it, since it can sync from P2P as well in parallel.
@@ -181,11 +186,6 @@ func (m *Manager) Start(ctx context.Context) error {
 		go uevent.MustSubscribe(ctx, m.Pubsub, "applyBlockSyncBlocksLoop", p2p.EventQueryNewBlockSyncBlock, m.onReceivedBlock, m.logger)
 	}
 
-	go func() {
-		_ = eg.Wait() // errors are already logged
-		m.logger.Info("Block manager err group finished.")
-	}()
-
 	return nil
 }
 

go.mod

@@ -288,7 +288,7 @@ require (
 	github.com/whyrusleeping/chunker v0.0.0-20181014151217-fe64bd25879f // indirect
 	go.uber.org/mock v0.4.0 // indirect
 	golang.org/x/tools v0.18.0 // indirect
-	pgregory.net/rapid v1.1.0 // indirect
+	pgregory.net/rapid v1.1.0
 )
 
 replace (