summaryrefslogtreecommitdiff
path: root/src/main/kotlin/dev/dnpm/etl/processor
diff options
context:
space:
mode:
authorPaul-Christian Volkmer2023-08-02 16:23:16 +0200
committerPaul-Christian Volkmer2023-08-02 16:23:16 +0200
commit7f8b21efd2273bb7b4ee0d93ff4988bade2fa610 (patch)
tree33c870f7239b066a070f34fcdb1b726af1654a0c /src/main/kotlin/dev/dnpm/etl/processor
parent70d4fa2f0ff4b38757cabc967b3f38a63674ed47 (diff)
Handle not parsable data quality reports
Diffstat (limited to 'src/main/kotlin/dev/dnpm/etl/processor')
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/monitoring/ReportService.kt12
1 files changed, 9 insertions, 3 deletions
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ReportService.kt b/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ReportService.kt
index 6ee8ae9..8c31ede 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ReportService.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/monitoring/ReportService.kt
@@ -20,6 +20,7 @@
package dev.dnpm.etl.processor.monitoring
import com.fasterxml.jackson.annotation.JsonValue
+import com.fasterxml.jackson.core.JsonParseException
import com.fasterxml.jackson.databind.JsonMappingException
import com.fasterxml.jackson.databind.ObjectMapper
@@ -33,9 +34,14 @@ class ReportService(
}
return try {
objectMapper.readValue(dataQualityReport, DataQualityReport::class.java).issues
- } catch (e: JsonMappingException) {
- e.printStackTrace()
- listOf()
+ } catch (e: Exception) {
+ val otherIssue =
+ Issue(Severity.ERROR, "Not parsable data quality report '$dataQualityReport'")
+ return when (e) {
+ is JsonMappingException -> listOf(otherIssue)
+ is JsonParseException -> listOf(otherIssue)
+ else -> throw e
+ }
}
}