From 61e55a54ee9435c5decf7efcbf24a469cc1123f3 Mon Sep 17 00:00:00 2001 From: Levi Ramsey Date: Wed, 22 Oct 2025 13:02:39 -0400 Subject: [PATCH] ensure that we start from latestBacktracking in events-by-slice --- .../akka/persistence/dynamodb/internal/BySliceQuery.scala | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala b/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala index 8ff9217..b8f9f54 100644 --- a/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala +++ b/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala @@ -71,11 +71,8 @@ import org.slf4j.Logger else latest def nextQueryFromTimestamp(backtrackingWindow: JDuration): Instant = - if (backtracking) { - if (latest.timestamp.minus(backtrackingWindow).isAfter(latestBacktracking.timestamp)) - latest.timestamp.minus(backtrackingWindow) - else latestBacktracking.timestamp - } else latest.timestamp + if (backtracking) latestBacktracking.timestamp + else latest.timestamp def nextQueryToTimestamp: Option[Instant] = { if (backtracking) Some(latest.timestamp)