diff --git a/service/data-hub/data-connector/src/modules/feat-anomalies/anomalies.service.ts b/service/data-hub/data-connector/src/modules/feat-anomalies/anomalies.service.ts index 3d5c49b..1598c83 100644 --- a/service/data-hub/data-connector/src/modules/feat-anomalies/anomalies.service.ts +++ b/service/data-hub/data-connector/src/modules/feat-anomalies/anomalies.service.ts @@ -62,9 +62,11 @@ export class AnomaliesService { const validatedAnomalies = anomalies.flat(); const updatedAnomalies: Anomaly[] = []; for (const anomaly of validatedAnomalies) { - updatedAnomalies.push( - await this.anomalyService.resolveAnomaly(anomaly.id), - ); + if (anomaly.resolvedAt) { + updatedAnomalies.push( + await this.anomalyService.resolveAnomaly(anomaly.id), + ); + } } return updatedAnomalies; });