Clean up misc state machine (#3518)

AudiusProject · Jul 20, 2022 · 338f8eb · 338f8eb
1 parent bfc6505
commit 338f8eb
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/creator-node/src/services/stateMachineManager/index.js b/creator-node/src/services/stateMachineManager/index.js
@@ -4,7 +4,6 @@ const config = require('../../config')
 const { logger: baseLogger } = require('../../logging')
 const StateMonitoringManager = require('./stateMonitoring')
 const StateReconciliationManager = require('./stateReconciliation')
-const NodeToSpIdManager = require('./CNodeToSpIdMapManager')
 const { RECONFIG_MODES } = require('./stateMachineConstants')
 const QueueInterfacer = require('./QueueInterfacer')
 const makeOnCompleteCallback = require('./makeOnCompleteCallback')

diff --git a/creator-node/src/services/stateMachineManager/makeOnCompleteCallback.js b/creator-node/src/services/stateMachineManager/makeOnCompleteCallback.js
@@ -65,7 +65,7 @@ module.exports = function (
       logger.info(`Job successfully completed. Parsing result: ${resultString}`)
       jobResult = JSON.parse(resultString) || {}
     } catch (e) {
-      logger.warn(`Failed to parse job result string`)
+      logger.error(`Failed to parse job result string`)
       return
     }
 

diff --git a/creator-node/src/services/stateMachineManager/stateMachineConstants.js b/creator-node/src/services/stateMachineManager/stateMachineConstants.js
@@ -14,6 +14,9 @@ module.exports = {
   // Max millis to run a StateReconciliationQueue job for before marking it as stalled (1 hour)
   STATE_RECONCILIATION_QUEUE_MAX_JOB_RUNTIME_MS: 1000 * 60 * 60,
 
+  // Max millis to run a manual sync job for before marking it as stalled (60 seconds)
+  MANUAL_SYNC_QUEUE_MAX_JOB_RUNTIME_MS: 1000 * 60,
+
   // Millis to timeout request for getting users who have a node as their primary/secondary (60 seconds)
   GET_NODE_USERS_TIMEOUT_MS: 1000 * 60,