bytelyst/learning_ai_common_plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(exports): preserve processing state on async export failures

Browse Source
This commit is contained in:
saravanakumardb1 2026-03-22 11:58:54 -07:00
parent 265599d005
commit 67ef6a6068
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/platform-service/src/modules/exports/routes.ts
View File

@ -63,17 +63,18 @@ export async function exportRoutes(app: FastifyInstance) {
// Process async — respond immediately, update job status when done // Process async — respond immediately, update job status when done
const log = req.log; const log = req.log;
process.nextTick(async () => { process.nextTick(async () => {
let currentJob = created;
try { try {
const processingJob = await repo.updateExportJob({ currentJob = await repo.updateExportJob({
...created, ...currentJob,
status: 'processing', status: 'processing',
startedAt: new Date().toISOString(), startedAt: new Date().toISOString(),
}); });
const rows = await fetchExportData(created.type, access.productId, created.filters); const rows = await fetchExportData(created.type, access.productId, created.filters);
const serialized = created.format === 'json' ? JSON.stringify(rows, null, 2) : toCsv(rows); const serialized = created.format === 'json' ? JSON.stringify(rows, null, 2) : toCsv(rows);
const fileName = `${created.type}-${access.productId}-${Date.now()}.${created.format}`; const fileName = `${created.type}-${access.productId}-${Date.now()}.${created.format}`;
await repo.updateExportJob({ currentJob = await repo.updateExportJob({
...processingJob, ...currentJob,
status: 'ready', status: 'ready',
data: serialized, data: serialized,
rowCount: rows.length, rowCount: rows.length,
@ -86,7 +87,7 @@ export async function exportRoutes(app: FastifyInstance) {
log.error({ err, exportId: created.id }, '[exports] Export job failed'); log.error({ err, exportId: created.id }, '[exports] Export job failed');
await repo await repo
.updateExportJob({ .updateExportJob({
...created, ...currentJob,
status: 'failed', status: 'failed',
error: err instanceof Error ? err.message : 'Unknown error', error: err instanceof Error ? err.message : 'Unknown error',
completedAt: new Date().toISOString(), completedAt: new Date().toISOString(),