From 23e2d8f2d4f001cda03d510e3a345ac4a5578668 Mon Sep 17 00:00:00 2001 From: Ketsia Date: Thu, 6 Apr 2023 14:01:56 -0700 Subject: [PATCH] WIP testing consistent query --- service/history/historyEngine.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/service/history/historyEngine.go b/service/history/historyEngine.go index ecdde05579..a0d3110782 100644 --- a/service/history/historyEngine.go +++ b/service/history/historyEngine.go @@ -1165,9 +1165,8 @@ func (e *historyEngineImpl) QueryWorkflow( if !consistentQueryEnabled { return nil, workflow.ErrConsistentQueryNotEnabled } - scope.IncCounter(metrics.ConsistentQueryPerShard) shardMetricScope.IncCounter(metrics.ConsistentQueryPerShard) - e.logger.SampleInfo("History QueryWorkflow called with QueryConsistencyLevelStrong", e.config.SampleLoggingRate(), tag.WorkflowID(request.GetRequest().Execution.WorkflowID), tag.WorkflowDomainName(request.GetRequest().Domain)) + e.logger.SampleInfo("History QueryWorkflow called with QueryConsistencyLevelStrong", e.config.SampleLoggingRate(), tag.ShardID(e.shard.GetShardID()), tag.WorkflowID(request.GetRequest().Execution.WorkflowID), tag.WorkflowDomainName(request.GetRequest().Domain)) } execution := *request.GetRequest().GetExecution()