diff --git a/server/src/api/record.ts b/server/src/api/record.ts index ead580f7..d395d3bf 100644 --- a/server/src/api/record.ts +++ b/server/src/api/record.ts @@ -326,7 +326,7 @@ async function executeRun(id: string) { }); let totalRowsExtracted = 0; - updatedRun.serializableOutput['item-0'].forEach((item: any) => { + updatedRun.dataValues.serializableOutput['item-0'].forEach((item: any) => { totalRowsExtracted += Object.keys(item).length; } ); @@ -338,9 +338,9 @@ async function executeRun(id: string) { runId: id, created_at: new Date().toISOString(), status: 'success', - extractedItemsCount: updatedRun.serializableOutput['item-0'].length, + extractedItemsCount: updatedRun.dataValues.serializableOutput['item-0'].length, extractedRowsCount: totalRowsExtracted, - extractedScreenshotsCount: updatedRun.binaryOutput['item-0'].length, + extractedScreenshotsCount: updatedRun.dataValues.binaryOutput['item-0'].length, } }) diff --git a/server/src/routes/storage.ts b/server/src/routes/storage.ts index f120a7a1..18ed7a6b 100644 --- a/server/src/routes/storage.ts +++ b/server/src/routes/storage.ts @@ -255,7 +255,7 @@ router.post('/runs/run/:id', requireSignIn, async (req: AuthenticatedRequest, re }); let totalRowsExtracted = 0; - run.serializableOutput['item-0'].forEach((item: any) => { + run.dataValues.serializableOutput['item-0'].forEach((item: any) => { totalRowsExtracted += Object.keys(item).length; } ); @@ -268,9 +268,9 @@ router.post('/runs/run/:id', requireSignIn, async (req: AuthenticatedRequest, re user_id: req.user?.id, created_at: new Date().toISOString(), status: 'success', - extractedItemsCount: run.serializableOutput['item-0'].length, + extractedItemsCount: run.dataValues.serializableOutput['item-0'].length, extractedRowsCount: totalRowsExtracted, - extractedScreenshotsCount: run.binaryOutput['item-0'].length, + extractedScreenshotsCount: run.dataValues.binaryOutput['item-0'].length, } }) try { diff --git a/server/src/workflow-management/scheduler/index.ts b/server/src/workflow-management/scheduler/index.ts index 094f4c05..c99849f7 100644 --- a/server/src/workflow-management/scheduler/index.ts +++ b/server/src/workflow-management/scheduler/index.ts @@ -134,7 +134,7 @@ async function executeRun(id: string) { }); let totalRowsExtracted = 0; - run.serializableOutput['item-0'].forEach((item: any) => { + run.dataValues.serializableOutput['item-0'].forEach((item: any) => { totalRowsExtracted += Object.keys(item).length; } ); @@ -146,9 +146,9 @@ async function executeRun(id: string) { runId: id, created_at: new Date().toISOString(), status: 'success', - extractedItemsCount: run.serializableOutput['item-0'].length, + extractedItemsCount: run.dataValues.serializableOutput['item-0'].length, extractedRowsCount: totalRowsExtracted, - extractedScreenshotsCount: run.binaryOutput['item-0'].length, + extractedScreenshotsCount: run.dataValues.binaryOutput['item-0'].length, } });