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