diff --git a/tests/cache/jobQueue/getHierarchy.js b/tests/cache/jobQueue/getHierarchy.js index 198a44545b..d56e265f0d 100644 --- a/tests/cache/jobQueue/getHierarchy.js +++ b/tests/cache/jobQueue/getHierarchy.js @@ -12,6 +12,7 @@ 'use strict'; const jobQueue = require('../../../jobQueue/setup').jobQueue; const jobType = require('../../../jobQueue/setup').jobType; +const getHierarchyJob = require('../../../worker/jobs/getHierarchyJob'); const expect = require('chai').expect; const supertest = require('supertest'); const api = supertest(require('../../../index').app); @@ -28,7 +29,7 @@ describe(`api: GET using worker process ${path}`, () => { before(() => { tu.toggleOverride('enableWorkerProcess', true); tu.toggleOverride('enqueueHierarchy', true); - require('../../../worker/jobProcessor'); + jobQueue.process(jobType.GET_HIERARCHY, getHierarchyJob); }); before(() => { diff --git a/tests/jobQueue/v1/getHierarchy.js b/tests/jobQueue/v1/getHierarchy.js index 0155c25b3f..1adcfdfc60 100644 --- a/tests/jobQueue/v1/getHierarchy.js +++ b/tests/jobQueue/v1/getHierarchy.js @@ -12,6 +12,7 @@ 'use strict'; const jobQueue = require('../../../jobQueue/setup').jobQueue; const jobType = require('../../../jobQueue/setup').jobType; +const getHierarchyJob = require('../../../worker/jobs/getHierarchyJob'); const expect = require('chai').expect; const supertest = require('supertest'); const api = supertest(require('../../../index').app); @@ -27,7 +28,7 @@ describe(`api: GET using worker process ${path}`, () => { before(() => { tu.toggleOverride('enableWorkerProcess', true); tu.toggleOverride('enqueueHierarchy', true); - require('../../../worker/jobProcessor'); + jobQueue.process(jobType.GET_HIERARCHY, getHierarchyJob); }); before(() => {