From 7ba2246cee133917509f20a4b6a6683ce443c085 Mon Sep 17 00:00:00 2001 From: Benjie Gillam Date: Fri, 26 Apr 2024 15:55:54 +0100 Subject: [PATCH] Test --- __tests__/workerUtils.cleanup.test.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/__tests__/workerUtils.cleanup.test.ts b/__tests__/workerUtils.cleanup.test.ts index 61268e9e..2c50844a 100644 --- a/__tests__/workerUtils.cleanup.test.ts +++ b/__tests__/workerUtils.cleanup.test.ts @@ -80,6 +80,7 @@ test("cleanup with GC_JOB_QUEUES", () => [WORKER_ID_1, "test", "test_job1"], [WORKER_ID_2, "test2", "test_job2"], [WORKER_ID_3, "test3", "test_job3"], + [null, null, "test_job4"], ] as const; for (const [workerId, queueName, taskIdentifier] of specs) { date.setMinutes(date.getMinutes() - 1); @@ -121,8 +122,8 @@ select * from j`, ]); await utils.forceUnlockWorkers(["worker3"]); - const lastJob = jobs[jobs.length - 1]; // Belongs to queueName 'task3' - await utils.completeJobs([lastJob.id]); + const thirdJob = jobs[2]; // Belongs to queueName 'task3' + await utils.completeJobs([thirdJob.id]); await utils.cleanup({ tasks: ["GC_JOB_QUEUES"] }); const { rows: queuesAfter } = await pgClient.query<{ queue_name: string }>( `select queue_name from ${ESCAPED_GRAPHILE_WORKER_SCHEMA}._private_job_queues`,