refactor groupAndConvertItemsToCheckpointWithPartitioningDTOs

AbsaOSS · Nov 22, 2024 · 7e4513a · 7e4513a
1 parent 0c520c5
commit 7e4513a
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/...er/src/main/scala/za/co/absa/atum/server/model/CheckpointItemWithPartitioningFromDB.scala b/...er/src/main/scala/za/co/absa/atum/server/model/CheckpointItemWithPartitioningFromDB.scala
@@ -113,12 +113,8 @@ object CheckpointItemWithPartitioningFromDB {
 
     val result = orderedCheckpointIds.map { id => fromItemsToCheckpointWithPartitioningDTO(groupedItems(id)) }
 
-    val errors = result.collect { case Left(err) => err }
-    if (errors.nonEmpty) {
-      Left(errors.head)
-    } else {
-      Right(result.collect { case Right(dto) => dto })
-    }
+    val error = result.collectFirst { case Left(err) => Left(err) }
+    error.getOrElse(Right(result.collect { case Right(dto) => dto }))
   }
 
 }