Skip to content

Commit d48e897

Browse files
committed
Modify CN state machine params for prod to improve throughput (#3855)
* Enable recoverOrphanedDataQueue (heavily throttled) * Increase maxRecurringRequestSyncJobConcurrency on prod from 30 to 50 * Increase maxUpdateReplicaSetJobConcurrency prod from 15 to 25 * 10x prod recurringSyncQueue.maxWaitingJobs from 10k to 100k; 10x prod updateReplicaSetQueue.maxWaitingJobs from 1k to 10k
1 parent 838a22a commit d48e897

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

creator-node/src/config.js

+3-3
Original file line numberDiff line numberDiff line change
@@ -488,7 +488,7 @@ const config = convict({
488488
doc: 'number of recover-orphaned-data jobs that can run in each interval (0 to pause queue)',
489489
format: 'nat',
490490
env: 'recoverOrphanedDataQueueRateLimitJobsPerInterval',
491-
default: 0
491+
default: 1
492492
},
493493
debounceTime: {
494494
doc: 'sync debounce time in ms',
@@ -554,13 +554,13 @@ const config = convict({
554554
doc: 'Max bull queue concurrency for recurring sync request jobs',
555555
format: 'nat',
556556
env: 'maxRecurringRequestSyncJobConcurrency',
557-
default: 30
557+
default: 50
558558
},
559559
maxUpdateReplicaSetJobConcurrency: {
560560
doc: 'Max bull queue concurrency for update replica set jobs',
561561
format: 'nat',
562562
env: 'maxUpdateReplicaSetJobConcurrency',
563-
default: 15
563+
default: 25
564564
},
565565
peerHealthCheckRequestTimeout: {
566566
doc: 'Timeout [ms] for checking health check route',

creator-node/src/services/stateMachineManager/index.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -71,11 +71,11 @@ class StateMachineManager {
7171
},
7272
[QUEUE_NAMES.RECURRING_SYNC]: {
7373
queue: recurringSyncQueue,
74-
maxWaitingJobs: 10000
74+
maxWaitingJobs: 100000
7575
},
7676
[QUEUE_NAMES.UPDATE_REPLICA_SET]: {
7777
queue: updateReplicaSetQueue,
78-
maxWaitingJobs: 1000
78+
maxWaitingJobs: 10000
7979
},
8080
[QUEUE_NAMES.RECOVER_ORPHANED_DATA]: {
8181
queue: recoverOrphanedDataQueue,

0 commit comments

Comments
 (0)