committer rpc parallel calls env

Author: nischitpra

configs/config.go

@@ -288,6 +288,7 @@ type Config struct {
 	StagingS3AccessKeyID             string `env:"STAGING_S3_ACCESS_KEY_ID"`
 	StagingS3SecretAccessKey         string `env:"STAGING_S3_SECRET_ACCESS_KEY"`
 	StagingS3MaxParallelFileDownload int    `env:"STAGING_S3_MAX_PARALLEL_FILE_DOWNLOAD" envDefault:"2"`
+	CommitterRPCNumParallelCalls     int64  `env:"COMMITTER_RPC_NUM_PARALLEL_CALLS" envDefault:"10"`
 }
 
 var Cfg Config

internal/committer/committer.go

@@ -726,15 +726,14 @@ func fetchLatest(nextCommitBlockNumber *big.Int) error {
 			continue
 		}
 
-		// Configuration variables
-		rpcBatchSize := int64(50)                               // Number of blocks per batch
-		rpcNumParallelCalls := int64(10)                        // Maximum number of parallel RPC calls
-		maxBlocksPerFetch := rpcBatchSize * rpcNumParallelCalls // Total blocks per fetch cycle
+		rpcNumParallelCalls := config.Cfg.CommitterRPCNumParallelCalls
+		rpcBatchSize := int64(50)
+		maxBlocksPerFetch := rpcBatchSize * rpcNumParallelCalls
 
 		// Calculate the range of blocks to fetch
 		blocksToFetch := new(big.Int).Sub(latestBlock, nextCommitBlockNumber)
 		if blocksToFetch.Cmp(big.NewInt(maxBlocksPerFetch)) > 0 {
-			blocksToFetch = big.NewInt(maxBlocksPerFetch) // Limit to maxBlocksPerFetch blocks per batch
+			blocksToFetch = big.NewInt(maxBlocksPerFetch)
 		}
 
 		log.Info().