diff options
| author | Paul-Christian Volkmer | 2023-08-02 16:23:16 +0200 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2023-08-02 16:23:16 +0200 |
| commit | 7f8b21efd2273bb7b4ee0d93ff4988bade2fa610 (patch) | |
| tree | 33c870f7239b066a070f34fcdb1b726af1654a0c /src/main | |
| parent | 70d4fa2f0ff4b38757cabc967b3f38a63674ed47 (diff) | |
Handle not parsable data quality reports
Diffstat (limited to 'src/main')
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/monitoring/ReportService.kt | 12 |
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 + } } } |
