53ffd705c4
Job queue starts only in the CLI gate (not inside createApp), so tests manage their own queue lifecycle. waitForJob() takes a (name, id) pair to match pg-boss v10's getJobById signature. Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
20 lines
793 B
JavaScript
20 lines
793 B
JavaScript
import * as queue from '../../lib/jobs/queue.js';
|
|
import { pool } from '../../lib/db/pool.js';
|
|
|
|
export async function stopBoss() {
|
|
try { await queue.stop(); } catch { /* ignore */ }
|
|
try { await pool.query('DROP SCHEMA IF EXISTS pgboss CASCADE'); } catch { /* ignore */ }
|
|
}
|
|
|
|
export async function waitForJob(name, id, { timeoutMs = 5_000 } = {}) {
|
|
const boss = queue.instance();
|
|
if (!boss) throw new Error('queue not started');
|
|
const start = Date.now();
|
|
while (Date.now() - start < timeoutMs) {
|
|
const j = await boss.getJobById(name, id, { includeArchive: true });
|
|
if (j && ['completed','failed','cancelled','expired'].includes(j.state)) return j;
|
|
await new Promise(r => setTimeout(r, 50));
|
|
}
|
|
throw new Error(`job ${name} ${id} did not finish in ${timeoutMs} ms`);
|
|
}
|