change input

smartcontractkit · Jan 2, 2025 · 8468443 · 8468443
1 parent c279cbb
commit 8468443
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/core/services/ocr2/plugins/ccip/ccipexec/initializers.go b/core/services/ocr2/plugins/ccip/ccipexec/initializers.go
@@ -43,7 +43,9 @@ var (
 	// 5s for token data worker timeout is a reasonable default.
 	tokenDataWorkerTimeout = 5 * time.Second
 	// tokenDataWorkerNumWorkers is the number of workers that will be processing token data in parallel.
-	tokenDataWorkerNumWorkers = 5
+	tokenDataWorkerNumWorkers = 10
+	// expirationDur is the duration for which the token data will be cached.
+	expirationDurTokenData = 10 * time.Minute
 )
 
 var defaultNewReportingPluginRetryConfig = ccipdata.RetryConfig{
@@ -169,7 +171,7 @@ func NewExecServices(ctx context.Context, lggr logger.Logger, jb job.Job, srcPro
 		tokenDataProviders,
 		tokenDataWorkerNumWorkers,
 		tokenDataWorkerTimeout,
-		2*tokenDataWorkerTimeout,
+		expirationDurTokenData,
 	)
 
 	wrappedPluginFactory := NewExecutionReportingPluginFactory(ExecutionPluginStaticConfig{

diff --git a/core/services/ocr2/plugins/ccip/tokendata/bgworker.go b/core/services/ocr2/plugins/ccip/tokendata/bgworker.go
@@ -60,7 +60,7 @@ func NewBackgroundWorker(
 	return &BackgroundWorker{
 		tokenDataReaders: tokenDataReaders,
 		numWorkers:       numWorkers,
-		jobsChan:         make(chan cciptypes.EVM2EVMOnRampCCIPSendRequestedWithMeta, numWorkers*100),
+		jobsChan:         make(chan cciptypes.EVM2EVMOnRampCCIPSendRequestedWithMeta, numWorkers*200),
 		resultsCache:     cache.New(expirationDur, expirationDur/2),
 		timeoutDur:       timeoutDur,