igneum-network/igneum
1
0
Fork 0
Code Issues Pull requests Releases Activity

build-job.mjs: the watcher reads the SUMMARY wherever it sits in the report (the closing report starts with the app header; two finished builds showed as still running on 5 October 2026)

Browse source 
Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
This commit is contained in:
igneum-labs 2026-10-05 16:02:47 +00:00
parent e07b5d2ba1
commit 2b4f89b5bc
1 changed files with 14 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
tools/build-job.mjs
View file

@ -54,13 +54,24 @@ function db() {
return j.rows;
};
}
const summaryOf = lines => { const l = (lines || '').split('\n')[0]; if (!l.startsWith('SUMMARY ')) return null; try { return JSON.parse(l.slice(8)); } catch { return null; } };
// the closing SUMMARY line wherever it sits in the report (5 October 2026: it was read from line 0 only, so a report whose
// first line is a STAGE or RESULT line hid a finished job and the watcher said "still running" past two done builds)
const summaryOf = lines => { for (const l of (lines || '').split('\n')) { if (!l.startsWith('SUMMARY ')) continue; try { return JSON.parse(l.slice(8)); } catch { return null; } } return null; };
const FINAL = new Set(['done', 'failed', 'timeout', 'aborted']);
/// The newest report per machine for the job: { machine, summary, lines[] }.
async function reports(sql, id) {
const rows = await sql(`SELECT DISTINCT ON (run_id) run_id, machine, received_at, lines FROM miner_logs WHERE run_id LIKE $1 AND label LIKE 'job-%' ORDER BY run_id, received_at DESC`, [`job-${id}-%`]);
return rows.map(r => ({ run_id: r.run_id, machine: r.machine, received_at: r.received_at, summary: summaryOf(r.lines), lines: (r.lines || '').split('\n') }));
// every report of the job, newest first; per run the newest row that carries a SUMMARY wins (a progress upload can
// land after the closing report), else the newest row
const rows = await sql(`SELECT run_id, machine, received_at, lines FROM miner_logs WHERE run_id LIKE $1 AND label LIKE 'job-%' ORDER BY run_id, received_at DESC`, [`job-${id}-%`]);
const byRun = new Map();
for (const r of rows) {
const cur = byRun.get(r.run_id);
const sum = summaryOf(r.lines);
if (!cur) { byRun.set(r.run_id, { ...r, summary: sum }); continue; }
if (!cur.summary && sum) byRun.set(r.run_id, { ...r, summary: sum });
}
return [...byRun.values()].map(r => ({ run_id: r.run_id, machine: r.machine, received_at: r.received_at, summary: r.summary, lines: (r.lines || '').split('\n') }));
}
async function watch(id, quiet = false) {