Skip to content
This repository was archived by the owner on Mar 13, 2025. It is now read-only.

Commit 47c7db8

Browse files
topcoder-archive/topcoder-platform-u-bahn-app#638 - add info if record processing failed
1 parent 1051366 commit 47c7db8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/services/ProcessorService.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,13 +249,15 @@ async function processCreate (message) {
249249
const records = helper.parseExcel(file)
250250
const failedRecord = []
251251
let failedRecordsObjectKey
252+
let info
252253

253254
await Promise.map(records, record => processCreateRecord(record, failedRecord, message.payload.organizationId), { concurrency: config.PROCESS_CONCURRENCY_COUNT })
254255

255256
if (failedRecord.length > 0) {
256257
failedRecordsObjectKey = await helper.uploadFailedRecord(failedRecord, message.payload.objectKey)
258+
info = 'Not all records were processed successfully'
257259
}
258-
await helper.updateProcessStatus(message.payload.id, { status: 'completed', failedRecordsObjectKey })
260+
await helper.updateProcessStatus(message.payload.id, { status: 'completed', failedRecordsObjectKey, info })
259261
logger.info(`processing of the record(s) completed, id: ${message.payload.id}, success count: ${records.length - failedRecord.length}, fail count: ${failedRecord.length}`)
260262
} catch (err) {
261263
await helper.updateProcessStatus(message.payload.id, { status: 'failed', info: err.message })

0 commit comments

Comments
 (0)