task *persistencespb.AllocatedTaskInfo,
taskType enumspb.TaskQueueType,
ctx, cancel := context.WithTimeout(v.tqCtx, ioTimeout)
defer cancel()
namespaceID := task.Data.NamespaceId
workflowID := task.Data.WorkflowId
runID := task.Data.RunId
switch taskType {
case enumspb.TASK_QUEUE_TYPE_ACTIVITY:
resp, err := v.historyClient.IsActivityTaskValid(ctx, &historyservice.IsActivityTaskValidRequest{