fix: Fail faster

Signed-off-by: Ryan Roberts <ryan@blockchaintp.com>
blockchaintp · Sep 15, 2021 · ba393c7 · ba393c7
1 parent df0fe69
commit ba393c7
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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);