diff --git a/ledger/indexer-benchmark/src/app/scala/ledger/indexerbenchmark/Main.scala b/ledger/indexer-benchmark/src/app/scala/ledger/indexerbenchmark/Main.scala index f4488ab4c655..1356543829be 100644 --- a/ledger/indexer-benchmark/src/app/scala/ledger/indexerbenchmark/Main.scala +++ b/ledger/indexer-benchmark/src/app/scala/ledger/indexerbenchmark/Main.scala @@ -5,6 +5,7 @@ package com.daml.ledger.indexerbenchmark import java.nio.file.{Files, Paths} import java.util.concurrent.atomic.AtomicLong + import akka.NotUsed import akka.actor.ActorSystem import akka.stream.Materializer diff --git a/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/KeyValueConsumption.scala b/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/KeyValueConsumption.scala index f7d06d65de16..aa2e6fcb376a 100644 --- a/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/KeyValueConsumption.scala +++ b/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/KeyValueConsumption.scala @@ -59,9 +59,7 @@ object KeyValueConsumption { entry: DamlLogEntry, errorVersionSwitch: ValueSwitch[Status], recordTimeForUpdate: Option[Timestamp] = None, - )(implicit - loggingContext: LoggingContext - ): List[Update] = { + )(implicit loggingContext: LoggingContext): List[Update] = { val recordTimeFromLogEntry = PartialFunction.condOpt(entry.hasRecordTime) { case true => parseTimestamp(entry.getRecordTime) } diff --git a/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/api/KeyValueParticipantState.scala b/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/api/KeyValueParticipantState.scala index 359cf12f4b0f..f86832e6d412 100644 --- a/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/api/KeyValueParticipantState.scala +++ b/ledger/participant-state/kvutils/src/main/scala/com/daml/ledger/participant/state/kvutils/api/KeyValueParticipantState.scala @@ -3,6 +3,8 @@ package com.daml.ledger.participant.state.kvutils.api +import java.util.concurrent.CompletionStage + import akka.NotUsed import akka.stream.scaladsl.Source import com.daml.daml_lf_dev.DamlLf @@ -24,8 +26,6 @@ import com.daml.logging.LoggingContext import com.daml.metrics.Metrics import com.daml.telemetry.TelemetryContext -import java.util.concurrent.CompletionStage - /** Implements read and write operations required for running a participant server. * * Adapts [[LedgerReader]] and [[LedgerWriter]] interfaces to [[com.daml.ledger.participant.state.v2.ReadService]] and