Disable recurring sync processing in snapback (#3332)

AudiusProject · Jun 28, 2022 · 59420a4 · 59420a4
1 parent 123688a
commit 59420a4
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 9 deletions.
diff --git a/creator-node/src/snapbackSM/snapbackSM.js b/creator-node/src/snapbackSM/snapbackSM.js
@@ -286,16 +286,18 @@ class SnapbackSM {
       )
 
       // Initialize recurringSyncQueue job processor
-      this.recurringSyncQueue.process(
-        this.MaxRecurringRequestSyncJobConcurrency,
-        async (job) => {
-          try {
-            await this.processSyncOperation(job, SyncType.Recurring)
-          } catch (e) {
-            this.logError(`RecurringSyncQueue processing error ${e}`)
+      if (!this.nodeConfig.get('disableSnapback')) {
+        this.recurringSyncQueue.process(
+          this.MaxRecurringRequestSyncJobConcurrency,
+          async (job) => {
+            try {
+              await this.processSyncOperation(job, SyncType.Recurring)
+            } catch (e) {
+              this.logError(`RecurringSyncQueue processing error ${e}`)
+            }
           }
-        }
-      )
+        )
+      }
       this.inittedJobProcessors = true
     }
 

diff --git a/creator-node/test/snapbackSM.test.js b/creator-node/test/snapbackSM.test.js
@@ -103,6 +103,7 @@ describe('test SnapbackSM -- determineNewReplicaSet, sync queue, and reconfig mo
     const MaxRecurringRequestSyncJobConcurrency = 1
     nodeConfig.set('maxManualRequestSyncJobConcurrency', MaxManualRequestSyncJobConcurrency)
     nodeConfig.set('maxRecurringRequestSyncJobConcurrency', MaxRecurringRequestSyncJobConcurrency)
+    nodeConfig.set('disableSnapback', false)
 
     // Mock out the initial call to sync
     nock(constants.secondary1Endpoint)