From f09a26b8c81a187d19fcf05fd4070a8dc7597a52 Mon Sep 17 00:00:00 2001
From: Remy Haemmerle <Remy.Haemmerle@daml.com>
Date: Thu, 26 Sep 2024 14:14:24 +0200
Subject: [PATCH] fix

---
 .../src/main/scala/com/daml/metrics/InstrumentedGraph.scala     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/sdk/observability/metrics/src/main/scala/com/daml/metrics/InstrumentedGraph.scala b/sdk/observability/metrics/src/main/scala/com/daml/metrics/InstrumentedGraph.scala
index a80e645c22c7..ee7216b5fb9b 100644
--- a/sdk/observability/metrics/src/main/scala/com/daml/metrics/InstrumentedGraph.scala
+++ b/sdk/observability/metrics/src/main/scala/com/daml/metrics/InstrumentedGraph.scala
@@ -26,6 +26,8 @@ object InstrumentedGraph {
       delayTimer: Timer,
   ) extends BoundedSourceQueue[T] {
 
+    override def isCompleted: Boolean = delegate.isCompleted
+
     override def complete(): Unit = {
       delegate.complete()
       capacityCounter.dec(bufferSize.toLong)(MetricsContext.Empty)