diff --git a/service/history/replication/task_executor.go b/service/history/replication/task_executor.go index 8fbc6b485d7..6bc8c51c545 100644 --- a/service/history/replication/task_executor.go +++ b/service/history/replication/task_executor.go @@ -141,6 +141,7 @@ func (e *taskExecutorImpl) handleActivityTask( metrics.ServiceLatency.With(e.metricsHandler).Record( time.Since(startTime), metrics.OperationTag(metrics.SyncActivityTaskScope), + metrics.NamespaceTag(attr.GetNamespaceId()), ) }() @@ -238,6 +239,7 @@ func (e *taskExecutorImpl) handleHistoryReplicationTask( metrics.ServiceLatency.With(e.metricsHandler).Record( time.Since(startTime), metrics.OperationTag(metrics.HistoryReplicationTaskScope), + metrics.NamespaceTag(attr.GetNamespaceId()), ) }()