137
sourceShardKey ClusterShardKey,
138
replicationTask *replicationspb.ReplicationTask,
140
>
return &ExecutableTaskImpl{
141
>
ProcessToolBox: processToolBox,
142
>
taskID: taskID,
143
>
metricsTag: metricsTag,
144
>
taskCreationTime: taskCreationTime,
145
>
taskReceivedTime: taskReceivedTime,
146
>
sourceClusterName: sourceClusterName,
147
>
sourceShardKey: sourceShardKey,
148
>
taskPriority: replicationTask.GetPriority(),
149
>
replicationTask: replicationTask,
150
>
taskState: taskStatePending,
151
>
attempt: 1,
152
>
markPoisonPillAttempts: 0,
153
>
}
154
>
}
155
156
func (e *ExecutableTaskImpl) TaskID() int64 {