Skip to content

Commit

Permalink
orderedCheckpointIds
Browse files Browse the repository at this point in the history
  • Loading branch information
salamonpavel committed Nov 22, 2024
1 parent e0f40a5 commit 353af66
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -106,12 +106,12 @@ object CheckpointItemWithPartitioningFromDB {
checkpointItems: Seq[CheckpointItemWithPartitioningFromDB]
): Either[Throwable, Seq[CheckpointWithPartitioningDTO]] = {
val groupedItems = checkpointItems.groupBy(_.idCheckpoint)
val orderedIds = checkpointItems
val orderedCheckpointIds = checkpointItems
.sortBy(_.checkpointStartTime)(Ordering[ZonedDateTime].reverse)
.map(_.idCheckpoint)
.distinct

val result = orderedIds.map { id =>
val result = orderedCheckpointIds.map { id =>
CheckpointItemWithPartitioningFromDB.fromItemsToCheckpointWithPartitioningDTO(groupedItems(id))
}

Expand Down

0 comments on commit 353af66

Please sign in to comment.