diff --git a/packages/fileimport-service/src/nextGen/main.ts b/packages/fileimport-service/src/nextGen/main.ts index a695008f6..2682d2c95 100644 --- a/packages/fileimport-service/src/nextGen/main.ts +++ b/packages/fileimport-service/src/nextGen/main.ts @@ -82,17 +82,22 @@ export const main = async () => { } if (err instanceof Error) { encounteredError = true - done(err) - await sendResult({ - ...job, - result: { - status: 'error', - reason: err.message, + try { + await sendResult({ + ...job, result: { - durationSeconds: 0 + status: 'error', + reason: err.message, + result: { + durationSeconds: 0 + } } - } - }) + }) + } catch (sendErr) { + jobLogger.fatal({ err: sendErr }, 'Failed to send result for job {jobId}') + } finally { + done(err) + } } else { throw err }