Skip to content

Commit

Permalink
WIP testing consistent query
Browse files Browse the repository at this point in the history
  • Loading branch information
ketsiambaku committed Apr 6, 2023
1 parent d2f9ec6 commit 23e2d8f
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions service/history/historyEngine.go
Expand Up @@ -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()
Expand Down

0 comments on commit 23e2d8f

Please sign in to comment.