50
sourceShardKey ClusterShardKey,
51
replicationTask *replicationspb.ReplicationTask,
53
>
task := replicationTask.GetVerifyVersionedTransitionTaskAttributes()
54
>
if task.ArchetypeId == chasm.UnspecifiedArchetypeID {
55
task.ArchetypeId = chasm.WorkflowArchetypeID
56
}
58
>
ProcessToolBox: processToolBox,
59
>
60
>
WorkflowKey: definition.NewWorkflowKey(task.NamespaceId, task.WorkflowId, task.RunId),
61
>
ExecutableTask: NewExecutableTask(
62
>
processToolBox,
63
>
taskID,
64
>
metrics.VerifyVersionedTransitionTaskScope,
65
>
taskCreationTime,
66
>
time.Now().UTC(),
67
>
sourceClusterName,
68
>
sourceShardKey,
69
>
replicationTask,
70
>
),
71
>
taskAttr: task,
72
>
}
73
}
74