Function failRun

server/modules/updateAudit.js:548–576

(traceContext, error, options = {})

}

async function failRun(traceContext, error, options = {}) {
  if (!traceContext) {
    return null;
  }

  const normalizedError = normalizeError(error, options.stage || "unknown");
  const finishedAt = options.finishedAt || new Date();
  const summary = sanitizePayload(options.summary || null);
  const payload = sanitizePayload({
    ...options.payload,
    ...normalizedError,
  });

  const runFailedEvent = await startEvent(traceContext, "run_failed", payload);
  await finishEvent(traceContext, runFailedEvent, "failed", payload);

  await updateRunContext(traceContext, {
    status: options.status || "failed",
    finishedAt,
    durationMs: getDurationMs(traceContext.startedAt || finishedAt, finishedAt),
    errorStage: normalizedError.errorStage,
    errorClass: normalizedError.errorClass,
    errorCode: normalizedError.errorCode,
    errorMessage: normalizedError.errorMessage,
    summary,
  });

  return traceContext;
}

async function recordInstantEvent(traceContext, stage, payload = {}, status = "success") {
  const event = await startEvent(traceContext, stage, payload);