+ it('covers error', async function () {
+ const expected = new Error('blah');
+ stubDb.context.restore();
+ sinon.stub(stubDb, 'context').rejects(expected);
+ await worker.process();
+ assert.strictEqual(worker._getWork.callCount, 0);
+ assert.strictEqual(worker._recurr.callCount, 1);
+ });