135
taskDispatchRevisionNumber int64,
136
targetVersion *deploymentspb.WorkerDeploymentVersion,
138
>
var redirectInfo *taskqueuespb.BuildIdRedirectInfo
139
>
// if this task is not forwarded, source can only be history
140
>
source := enumsspb.TASK_SOURCE_HISTORY
141
>
if forwardInfo != nil {
142
// if task is forwarded, it may be history or backlog. setting based on forward info
143
source = forwardInfo.TaskSource
144
redirectInfo = forwardInfo.GetRedirectInfo()
145
}
146
>
return &internalTask{
task.go
147
>
event: &genericTaskInfo{
148
>
AllocatedTaskInfo: &persistencespb.AllocatedTaskInfo{
149
>
Data: info,
150
>
TaskId: syncMatchTaskId,
151
>
},
152
>
},
153
>
forwardInfo: forwardInfo,
154
>
source: source,
155
>
redirectInfo: redirectInfo,
156
>
responseC: make(chan taskResponse, 1),
157
>
158
>
taskDispatchRevisionNumber: taskDispatchRevisionNumber,
159
>
targetWorkerDeploymentVersion: targetVersion,
160
>
161
>
effectivePriority: effectivePriorityFactor * priorityKey(info.GetPriority().GetPriorityKey()),
162
>
}
163
}
164