From a466c4da0cb48b00745bca06fc2ff12c975b3c5b Mon Sep 17 00:00:00 2001
From: wxing1292 <wxing1292@users.noreply.github.com>
Date: Thu, 13 Jul 2023 13:51:20 -0700
Subject: [PATCH] Fix metrics tagging in stream replication task processing
 (#4625)

<!-- Describe what has changed in this PR -->
**What changed?**
* Fix metrics tagging in stream replication task processing

<!-- Tell your future self why have you made these changes -->
**Why?**
Wrong tag is used

<!-- How have you verified this change? Tested locally? Added a unit
test? Checked in staging env? -->
**How did you test it?**
N/A

<!-- Assuming the worst case, what can be broken when deploying this
change to production? -->
**Potential risks**
N/A

<!-- Is this PR a hotfix candidate or require that a notification be
sent to the broader community? (Yes/No) -->
**Is hotfix candidate?**
Yes
---
 service/history/replication/executable_task.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/service/history/replication/executable_task.go b/service/history/replication/executable_task.go
index 005b2c4d453..1357b4dcfb3 100644
--- a/service/history/replication/executable_task.go
+++ b/service/history/replication/executable_task.go
@@ -172,7 +172,7 @@ func (e *ExecutableTaskImpl) Nack(err error) {
 	}
 	e.MetricsHandler.Counter(metrics.ReplicationTasksFailed.GetMetricName()).Record(
 		1,
-		metrics.OperationTag(metrics.SyncActivityTaskScope),
+		metrics.OperationTag(e.metricsTag),
 		metrics.NamespaceTag(namespaceName),
 	)
 }