diff --git a/src/classes/worker.ts b/src/classes/worker.ts index f9a2ce34ce..a88ae84c7b 100644 --- a/src/classes/worker.ts +++ b/src/classes/worker.ts @@ -597,7 +597,7 @@ export class Worker< this.blockUntil = await this.waiting; if (this.blockUntil <= 0 || this.blockUntil - Date.now() < 1) { - return this.moveToActive(client, token, this.opts.name); + return await this.moveToActive(client, token, this.opts.name); } } catch (err) { // Swallow error if locally paused or closing since we did force a disconnection diff --git a/tests/test_job_scheduler.ts b/tests/test_job_scheduler.ts index b00f108b53..1b866f7439 100644 --- a/tests/test_job_scheduler.ts +++ b/tests/test_job_scheduler.ts @@ -23,7 +23,7 @@ const ONE_DAY = 24 * ONE_HOUR; const NoopProc = async (job: Job) => {}; -describe.only('Job Scheduler', function () { +describe('Job Scheduler', function () { const redisHost = process.env.REDIS_HOST || 'localhost'; const prefix = process.env.BULLMQ_TEST_PREFIX || 'bull'; this.timeout(10000);