90
scope = scope.WithTags(metrics.StringTag("workflow_status", mutableStateStatus.String()))
91
if mutableStateStatus != enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING && req.QueryRejectCondition != enumspb.QUERY_REJECT_CONDITION_NONE {
92
>
notOpenReject := req.GetQueryRejectCondition() == enumspb.QUERY_REJECT_CONDITION_NOT_OPEN
api.go
93
>
notCompletedCleanlyReject := req.GetQueryRejectCondition() == enumspb.QUERY_REJECT_CONDITION_NOT_COMPLETED_CLEANLY && mutableStateStatus != enumspb.WORKFLOW_EXECUTION_STATUS_COMPLETED
94
>
if notOpenReject || notCompletedCleanlyReject {
95
>
return &historyservice.QueryWorkflowResponse{
96
>
Response: &workflowservice.QueryWorkflowResponse{
97
>
QueryRejected: &querypb.QueryRejected{
98
>
Status: mutableStateStatus,
99
>
},
100
>
},
101
>
}, nil
102
>
}
103
}
104
// If workflow is paused, return query rejected with PAUSED status.