move pool creation location

node/node.go

@@ -45,7 +45,6 @@ type Node struct {
 	Transactor              core.Transactor
 	PubIPProvider           pubip.Provider
 	OperatorSocketsFilterer indexer.OperatorSocketsFilterer
-	Pool                    common.WorkerPool
 
 	mu            sync.Mutex
 	CurrentSocket string
@@ -69,8 +68,6 @@ func NewNode(config *Config, pubIPProvider pubip.Provider, logger common.Logger)
 
 	config.ID = keyPair.GetPubKeyG1().GetOperatorID()
 
-	pool := workerpool.New(config.NumBatchValidators)
-
 	// Make sure config folder exists.
 	err = os.MkdirAll(config.DbPath, os.ModePerm)
 	if err != nil {
@@ -147,7 +144,6 @@ func NewNode(config *Config, pubIPProvider pubip.Provider, logger common.Logger)
 		Validator:               validator,
 		PubIPProvider:           pubIPProvider,
 		OperatorSocketsFilterer: socketsFilterer,
-		Pool:                    pool,
 	}, nil
 }
 
@@ -326,7 +322,8 @@ func (n *Node) ValidateBatch(ctx context.Context, header *core.BatchHeader, blob
 		return err
 	}
 
-	return n.Validator.ValidateBatch(blobs, operatorState, n.Pool)
+	pool := workerpool.New(n.Config.NumBatchValidators)
+	return n.Validator.ValidateBatch(blobs, operatorState, pool)
 }
 
 func (n *Node) updateSocketAddress(ctx context.Context, newSocketAddr string) {