Update repair queries fro latest Minion release

Author: kraih

src/pg-backend.ts

@@ -351,7 +351,11 @@ export class PgBackend {
     // Old jobs
     await pg.query`
       DELETE FROM minion_jobs
-      WHERE state = 'finished' AND finished <= NOW() - INTERVAL '1 millisecond' * ${minion.removeAfter}
+      WHERE id IN (
+        SELECT id FROM minion_jobs
+        WHERE state = 'finished' AND finished <= NOW() - INTERVAL '1 second' * ${minion.removeAfter}
+        EXCEPT SELECT unnest(parents) AS id FROM minion_jobs WHERE state != 'finished'
+      )
     `;
 
     // Expired jobs

test/pg.js

@@ -1027,9 +1027,9 @@ t.test('PostgreSQL backend', skip, async t => {
     t.same((await job4.info()).parents, [id, id2]);
     t.equal((await minion.stats()).finished_jobs, 2);
     await minion.repair();
-    t.equal((await minion.stats()).finished_jobs, 0);
+    t.equal((await minion.stats()).finished_jobs, 2);
     t.ok(await job4.finish());
-    t.equal((await minion.stats()).finished_jobs, 1);
+    t.equal((await minion.stats()).finished_jobs, 3);
     await minion.repair();
     t.equal((await minion.stats()).finished_jobs, 0);