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

fix(parse-progress): persist opId only after worker op exists

Browse source
This commit is contained in:
Richard R 2026-05-27 00:08:42 -06:00
parent c717f7e33e
commit 14b1b5602f
1 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/lib/server/jobs/user-pdf-layout-job.ts
View file

@ -1,4 +1,3 @@
import { randomUUID } from 'node:crypto';
import { and, eq, inArray, isNull } from 'drizzle-orm'; import { and, eq, inArray, isNull } from 'drizzle-orm';
import { db } from '@/db'; import { db } from '@/db';
import { documents } from '@/db/schema'; import { documents } from '@/db/schema';
@ -200,12 +199,10 @@ export async function parsePdfJob(input: UserPdfLayoutJobRequest): Promise<void>
const coordinator = [...scopedRows].sort((a, b) => a.userId.localeCompare(b.userId))[0]; const coordinator = [...scopedRows].sort((a, b) => a.userId.localeCompare(b.userId))[0];
if (!coordinator) return; if (!coordinator) return;
const claimOpId = randomUUID();
const runningStateData: DocumentParseState = { const runningStateData: DocumentParseState = {
status: 'running', status: 'running',
progress: null, progress: null,
updatedAt: Date.now(), updatedAt: Date.now(),
opId: claimOpId,
}; };
const runningState = stringifyDocumentParseState(runningStateData); const runningState = stringifyDocumentParseState(runningStateData);
@ -239,12 +236,12 @@ export async function parsePdfJob(input: UserPdfLayoutJobRequest): Promise<void>
}); });
const compute = await getCompute(); const compute = await getCompute();
let activeOpId: string = claimOpId; let activeOpId: string | undefined;
let activeJobId: string | undefined; let activeJobId: string | undefined;
let lastProgressWriteAt = 0; let lastProgressWriteAt = 0;
let lastSnapshotWriteAt = 0; let lastSnapshotWriteAt = 0;
let lastSnapshotStatus: 'pending' | 'running' | null = null; let lastSnapshotStatus: 'pending' | 'running' | null = null;
let lastSnapshotOpId: string = claimOpId; let lastSnapshotOpId: string | undefined;
let lastSnapshotJobId: string | undefined; let lastSnapshotJobId: string | undefined;
const persistRunningState = async (state: DocumentParseState): Promise<void> => { const persistRunningState = async (state: DocumentParseState): Promise<void> => {
@ -280,7 +277,7 @@ export async function parsePdfJob(input: UserPdfLayoutJobRequest): Promise<void>
status: mappedStatus, status: mappedStatus,
progress: snapshot.progress ?? null, progress: snapshot.progress ?? null,
updatedAt: now, updatedAt: now,
opId: activeOpId, ...(activeOpId ? { opId: activeOpId } : {}),
...(activeJobId ? { jobId: activeJobId } : {}), ...(activeJobId ? { jobId: activeJobId } : {}),
}; };
await persistRunningState(nextState); await persistRunningState(nextState);
@ -306,7 +303,7 @@ export async function parsePdfJob(input: UserPdfLayoutJobRequest): Promise<void>
phase: progress.phase, phase: progress.phase,
}, },
updatedAt: Date.now(), updatedAt: Date.now(),
opId: activeOpId, ...(activeOpId ? { opId: activeOpId } : {}),
...(activeJobId ? { jobId: activeJobId } : {}), ...(activeJobId ? { jobId: activeJobId } : {}),
}; };
await persistRunningState(runningProgressState); await persistRunningState(runningProgressState);