250
}
251
252
>
_, scheduleToStartTimeout := mutableState.TaskQueueScheduleToStartTimeout(transferTask.TaskQueue)
transfer_queue_standby_task_executor.go
253
>
// Task queue is ignored here because at standby, always use original normal task queue,
254
>
// disregards the transferTask.TaskQueue which could be sticky.
255
>
// NOTE: scheduleToStart timeout is respected. If workflow was sticky before namespace become standby,
256
>
// transferTask.TaskQueue is sticky, and there is timer already created for this timeout.
257
>
// Use this sticky timeout as TTL.
258
>
taskQueue := &taskqueuepb.TaskQueue{
259
>
Name: mutableState.GetExecutionInfo().TaskQueue,
260
>
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
261
>
}
262
>
263
>
err := CheckTaskVersion(t.shardContext, t.logger, mutableState.GetNamespaceEntry(), wtInfo.Version, transferTask.Version, transferTask)
264
>
if err != nil {
265
return nil, err
266
}
267
269
return newWorkflowTaskPostActionInfo(
270
mutableState,