50
sourceShardKey ClusterShardKey,
51
replicationTask *replicationspb.ReplicationTask,
53
>
return &ExecutableSyncHSMTask{
54
>
ProcessToolBox: processToolBox,
55
>
56
>
WorkflowKey: definition.NewWorkflowKey(task.NamespaceId, task.WorkflowId, task.RunId),
57
>
ExecutableTask: NewExecutableTask(
58
>
processToolBox,
59
>
taskID,
60
>
metrics.SyncHSMTaskScope,
61
>
taskCreationTime,
62
>
time.Now().UTC(),
63
>
sourceClusterName,
64
>
sourceShardKey,
65
>
replicationTask,
66
>
),
67
>
taskAttr: task,
68
>
}
69
>
}
70
71
func (e *ExecutableSyncHSMTask) QueueID() any {