diff --git a/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt b/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt index ebe89b5d4c..db697148cd 100644 --- a/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt +++ b/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt @@ -62,7 +62,6 @@ import org.apache.activemq.artemis.utils.ReusableLatch import org.slf4j.Logger import org.slf4j.LoggerFactory import org.slf4j.MDC -import java.time.Duration import java.util.concurrent.TimeUnit class FlowPermissionException(message: String) : FlowException(message) @@ -336,7 +335,7 @@ class FlowStateMachineImpl(override val id: StateMachineRunId, val startTime = System.nanoTime() serviceHub.monitoringService.metrics .timer("Flows.StartupQueueTime") - .update(Duration.ofNanos(startTime).toMillis() - creationTime, TimeUnit.MILLISECONDS) + .update(System.currentTimeMillis() - creationTime, TimeUnit.MILLISECONDS) var initialised = false val resultOrError = try {