diff --git a/docker/daml-test.yaml b/docker/daml-test.yaml
index d7bd36da..79ba9a95 100644
--- a/docker/daml-test.yaml
+++ b/docker/daml-test.yaml
@@ -69,22 +69,22 @@ services:
     entrypoint: "bash -xc \"\
       sleep 120  && \
       java -jar ledger-api-test-tool.jar \
-        --timeout-scale-factor 10 \
+        --timeout-scale-factor 2 \
         --concurrent-test-runs 1 \
         daml-on-qldb:9000 \
         || \
       java -jar ledger-api-test-tool.jar \
-        --timeout-scale-factor 10 \
+        --timeout-scale-factor 2 \
         --concurrent-test-runs 1 \
         daml-on-qldb:9000 \
         || \
       java -jar ledger-api-test-tool.jar \
-        --timeout-scale-factor 10 \
+        --timeout-scale-factor 2 \
         --concurrent-test-runs 1 \
         daml-on-qldb:9000 \
         || \
       java -jar ledger-api-test-tool.jar \
-        --timeout-scale-factor 10 \
+        --timeout-scale-factor 2 \
         --concurrent-test-runs 1 \
         daml-on-qldb:9000 \
         \""
diff --git a/src/main/java/com/blockchaintp/daml/participant/Participant.java b/src/main/java/com/blockchaintp/daml/participant/Participant.java
index e7fbc56f..9a01959b 100644
--- a/src/main/java/com/blockchaintp/daml/participant/Participant.java
+++ b/src/main/java/com/blockchaintp/daml/participant/Participant.java
@@ -114,7 +114,7 @@ public akka.stream.scaladsl.Source<LedgerRecord, NotUsed> events(final Option<Of
         .comparatorToOrdering(Comparator.comparingLong(scala.Long::unbox));
 
     var rangeSource = new RangeSource<>((s, e) -> Source
-        .fromJavaStream(() -> API.unchecked(() -> txLog.from(s - 1, Optional.of(e - 1))).apply()
+        .fromJavaStream(() -> API.unchecked(() -> txLog.from(s - 1, Optional.of(e))).apply()
             .map(r -> Tuple2.apply(r._1, LedgerRecord.apply(OffsetBuilder.fromLong(r._1, 0, 0), r._2, r._3))))
         .mapMaterializedValue(m -> NotUsed.notUsed()).asScala(), scalaLongOrdering);