180
taskID string,
181
request *matchingservice.QueryWorkflowRequest,
183
>
return &internalTask{
184
>
query: &queryTaskInfo{
185
>
taskID: taskID,
186
>
createTime: getCreateTime(request.GetForwardInfo()),
187
>
request: request,
188
>
},
189
>
forwardInfo: request.GetForwardInfo(),
190
>
responseC: make(chan taskResponse, 1),
191
>
source: enumsspb.TASK_SOURCE_HISTORY,
192
>
effectivePriority: effectivePriorityFactor * priorityKey(request.GetPriority().GetPriorityKey()),
193
>
}
194
>
}
195
196
func getCreateTime(f *taskqueuespb.TaskForwardInfo) *timestamppb.Timestamp {