get hierarchy worker

salesforce · Jun 1, 2017 · ad013f0 · ad013f0
1 parent 93e0fe6
commit ad013f0
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/jobQueue/jobWrapper.js b/jobQueue/jobWrapper.js
@@ -245,7 +245,7 @@ function createJob(jobName, data, req) {
       `jobPriority=${jobPriority}`);
   }
 
-  const job = jobQueue.create(jobName, data)
+  const job = jobQueue.create(jobName, data);
   job.ttl(TIME_TO_LIVE)
   .priority(jobPriority)
   .save((err) => {

diff --git a/jobQueue/setup.js b/jobQueue/setup.js
@@ -40,6 +40,7 @@ if (featureToggles.isFeatureEnabled('instrumentKue')) {
 module.exports = {
   jobConcurrency: {
     BULKUPSERTSAMPLES: conf.bulkUpsertSampleJobConcurrency,
+    GET_HIERARCHY: 1,
     PERSIST_SAMPLE_STORE: 1,
     SAMPLE_TIMEOUT: 1,
   },

diff --git a/worker/jobProcessor.js b/worker/jobProcessor.js
@@ -26,13 +26,11 @@ const getHierarchyJob = require('./jobs/getHierarchyJob');
 const workerStarted = 'Worker Process Started';
 console.log(workerStarted); // eslint-disable-line no-console
 
-
 jobQueue.process(jobType.BULKUPSERTSAMPLES, jobConcurrency.BULKUPSERTSAMPLES,
   bulkUpsertSamplesJob);
+jobQueue.process(jobType.GET_HIERARCHY, jobConcurrency.GET_HIERARCHY,
+  getHierarchyJob);
 jobQueue.process(jobType.SAMPLE_TIMEOUT, jobConcurrency.SAMPLE_TIMEOUT,
   sampleTimeoutJob);
 jobQueue.process(jobType.PERSIST_SAMPLE_STORE,
   jobConcurrency.PERSIST_SAMPLE_STORE, persistSampleStoreJob);
-jobQueue.process(jobType.GET_HIERARCHY, jobConcurrency.GET_HIERARCHY,
-  getHierarchyJob);
-