210
}
211
switch completionState.Type {
212
>
case workflow.QueryCompletionTypeSucceeded:
api.go
213
>
result := completionState.Result
214
>
switch result.GetResultType() {
215
>
case enumspb.QUERY_RESULT_TYPE_ANSWERED:
216
>
emitWorkflowQueryMetrics(
217
>
scope,
218
>
nsEntry,
219
>
msResp,
220
>
req.GetQuery().GetQueryType(),
221
>
nil,
222
>
)
223
>
return &historyservice.QueryWorkflowResponse{
224
>
Response: &workflowservice.QueryWorkflowResponse{
225
>
QueryResult: result.GetAnswer(),
226
>
},
227
>
}, nil
228
case enumspb.QUERY_RESULT_TYPE_FAILED:
229
err := serviceerror.NewQueryFailedWithFailure(result.GetErrorMessage(), result.GetFailure())