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

fix: clean up temp segment directory after conform job finishes

Browse source
This commit is contained in:
Zac Gaetano 2026-05-19 23:06:54 -04:00
parent 90bb0769e5
commit b175eaf54c
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
services/worker/src/workers/conform.js
View file

@ -1,5 +1,5 @@
import { join } from 'path'; import { join } from 'path';
import { unlink, writeFile, mkdir } from 'fs/promises'; import { unlink, writeFile, mkdir, rm } from 'fs/promises';
import { tmpdir } from 'os'; import { tmpdir } from 'os';
import { query } from '../db/client.js'; import { query } from '../db/client.js';
import { downloadFromS3, uploadToS3 } from '../s3/client.js'; import { downloadFromS3, uploadToS3 } from '../s3/client.js';
@ -97,11 +97,12 @@ export const conformWorker = async (job) => {
throw error; throw error;
} finally { } finally {
// Best-effort cleanup of temp files // Best-effort cleanup of all temp files and directories
await Promise.all([ await Promise.all([
unlink(edlPath).catch(() => {}), unlink(edlPath).catch(() => {}),
unlink(segmentListPath).catch(() => {}), unlink(segmentListPath).catch(() => {}),
unlink(outputPath).catch(() => {}), unlink(outputPath).catch(() => {}),
rm(segmentsDir, { recursive: true, force: true }).catch(() => {}),
]); ]);
} }
}; };