OpenSourceArk/Ghost
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improved job manager unit test stability

Browse Source
This commit is contained in:
Simon Backx 2023-01-30 17:26:30 +01:00
parent b9b51ee309
commit 8a153a83ad
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ghost/job-manager/test/job-manager.test.js
View File

@ -250,17 +250,17 @@ describe('Job Manager', function () {
it('uses worker message handler when job sends a message', async function (){ it('uses worker message handler when job sends a message', async function (){
const workerMessageHandlerSpy = sinon.spy(); const workerMessageHandlerSpy = sinon.spy();
const jobManager = new JobManager({workerMessageHandler: workerMessageHandlerSpy}); const jobManager = new JobManager({workerMessageHandler: workerMessageHandlerSpy});
const completion = jobManager.awaitCompletion('will-send-msg');
jobManager.addJob({ jobManager.addJob({
job: path.resolve(__dirname, './jobs/message.js'), job: path.resolve(__dirname, './jobs/message.js'),
name: 'will-send-msg' name: 'will-send-msg'
}); });
jobManager.bree.run('will-send-msg'); jobManager.bree.run('will-send-msg');
await delay(100);
jobManager.bree.workers['will-send-msg'].postMessage('hello from Ghost!'); jobManager.bree.workers['will-send-msg'].postMessage('hello from Ghost!');
// Give time for worker (worker thread) <-> parent process (job manager) communication await completion;
await delay(100);
should(workerMessageHandlerSpy.called).be.true(); should(workerMessageHandlerSpy.called).be.true();
should(workerMessageHandlerSpy.args[0][0].name).equal('will-send-msg'); should(workerMessageHandlerSpy.args[0][0].name).equal('will-send-msg');