WildDragonLLC/dragonflight
1
0
Fork 0
Code Issues 32 Pull requests 1 Projects Releases Packages Wiki Activity Actions

fix(scheduler): orphan grace window must use recorder.updated_at not asset.updated_at — asset is created at recording START not STOP

Browse source
This commit is contained in:
Zac Gaetano 2026-06-03 14:03:32 +00:00
parent 108390e823
commit c269468014
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
services/mam-api/src/scheduler.js
View file

@ -137,10 +137,11 @@ async function tick() {
// Orphaned live assets: recorder stopped but asset still 'live'. // Orphaned live assets: recorder stopped but asset still 'live'.
// Happens when the capture sidecar crashes before finalize() runs. // Happens when the capture sidecar crashes before finalize() runs.
// Wait 90s grace before marking error — this prevents a mam-api restart // Grace window is measured from when the RECORDER was last updated
// from racing the capture container's finalize() POST, which can take up // (i.e. when it transitioned to stopped), not from asset creation.
// to 30s for large files on a slow upload or busy node. // This prevents a race where the scheduler fires before the capture
const ORPHAN_GRACE_SECONDS = parseInt(process.env.ORPHAN_GRACE_SECONDS || '90', 10); // container's finalize POST lands (can take 30-60s on large files).
const ORPHAN_GRACE_SECONDS = parseInt(process.env.ORPHAN_GRACE_SECONDS || '120', 10);
const orphanResult = await client.query( const orphanResult = await client.query(
`UPDATE assets a `UPDATE assets a
SET status = 'error', updated_at = NOW() SET status = 'error', updated_at = NOW()
@ -148,7 +149,7 @@ async function tick() {
WHERE a.status = 'live' WHERE a.status = 'live'
AND a.display_name = r.current_session_id AND a.display_name = r.current_session_id
AND r.status = 'stopped' AND r.status = 'stopped'
AND a.updated_at < NOW() - ($1 || ' seconds')::INTERVAL AND r.updated_at < NOW() - ($1 || ' seconds')::INTERVAL
RETURNING a.id, a.display_name`, RETURNING a.id, a.display_name`,
[ORPHAN_GRACE_SECONDS] [ORPHAN_GRACE_SECONDS]
); );