danvics/openreader
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(jobs): make TTS segment cache invalidation non-blocking in parsePdfJob

Browse source 
Move TTS segment cache invalidation to a fire-and-forget promise after
document update to prevent cache errors from blocking parse readiness.
Log warnings for both cache invalidation failures and warnings, but do not
interrupt the main job flow. This improves job robustness and avoids
unnecessary failures due to cache issues.
This commit is contained in:
Richard R 2026-05-23 05:55:22 -06:00
parent 65d25e3ce5
commit df321b8832
1 changed files with 19 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
src/lib/server/jobs/parsePdfJob.ts
View file

@ -71,18 +71,6 @@ export async function parsePdfJob(input: ParsePdfJobInput): Promise<void> {
parsedJsonKey = await putParsedDocumentBlob(input.documentId, parsedJson, input.namespace);
}
const cleared = await clearTtsSegmentCache({
userId: input.userId,
documentId: input.documentId,
readerType: 'pdf',
});
if (cleared.warning) {
console.warn('[parsePdfJob] cache invalidation warning', {
documentId: input.documentId,
warning: cleared.warning,
});
}
await db
.update(documents)
.set({
@ -94,6 +82,25 @@ export async function parsePdfJob(input: ParsePdfJobInput): Promise<void> {
parsedJsonKey,
})
.where(and(eq(documents.id, input.documentId), eq(documents.userId, input.userId)));
// Best-effort cache invalidation should not block parse readiness.
void clearTtsSegmentCache({
userId: input.userId,
documentId: input.documentId,
readerType: 'pdf',
}).then((cleared) => {
if (cleared.warning) {
console.warn('[parsePdfJob] cache invalidation warning', {
documentId: input.documentId,
warning: cleared.warning,
});
}
}).catch((cacheError) => {
console.warn('[parsePdfJob] cache invalidation failed', {
documentId: input.documentId,
error: cacheError instanceof Error ? cacheError.message : String(cacheError),
});
});
} catch (error) {
const message = error instanceof Error ? error.message : String(error);
const stack = error instanceof Error ? error.stack : undefined;