Fix emit 0 count if encounters error (#4073)

cadence-workflow · Mar 25, 2021 · f3eaa11 · f3eaa11
1 parent dca153d
commit f3eaa11
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/common/domain/replication_queue.go b/common/domain/replication_queue.go
@@ -336,13 +336,14 @@ func (q *replicationQueueImpl) emitDLQSize() {
 				).IncCounter(
 					metrics.DomainReplicationQueueSizeErrorCount,
 				)
+			} else {
+				q.metricsClient.Scope(
+					metrics.DomainReplicationQueueScope,
+				).UpdateGauge(
+					metrics.DomainReplicationQueueSizeGauge,
+					float64(size),
+				)
 			}
-			q.metricsClient.Scope(
-				metrics.DomainReplicationQueueScope,
-			).UpdateGauge(
-				metrics.DomainReplicationQueueSizeGauge,
-				float64(size),
-			)
 		}
 	}
 }