192
}
193
194
>
resp, err := fwdr.client.QueryWorkflow(ctx, &matchingservice.QueryWorkflowRequest{
forwarder.go
195
>
NamespaceId: task.query.request.GetNamespaceId(),
196
>
TaskQueue: &taskqueuepb.TaskQueue{
197
>
Name: target.RpcName(),
198
>
Kind: fwdr.partition.Kind(),
199
>
},
200
>
QueryRequest: task.query.request.QueryRequest,
201
>
VersionDirective: task.query.request.VersionDirective,
202
>
ForwardInfo: fwdr.getForwardInfo(task),
203
>
})
204
>
205
>
return resp, fwdr.handleErr(err)
206
}
207