99
}
100
101
>
ctx, cancel := newTaskContext(namespaceName, e.Config.ReplicationTaskApplyTimeout(), callerInfo)
executable_backfill_history_events_task.go
102
>
defer cancel()
103
>
104
>
shardContext, err := e.ShardController.GetShardByNamespaceWorkflow(
105
>
namespace.ID(e.NamespaceID),
106
>
e.WorkflowID,
107
>
)
108
>
if err != nil {
109
return err
110
}
111
113
>
if err != nil {
114
return err
115
}
116
117
>
events, newRunEvents, err := e.getDeserializedEvents()
executable_backfill_history_events_task.go
118
>
if err != nil {
119
return err
120
}
121
122
>
return engine.BackfillHistoryEvents(ctx, &historyi.BackfillHistoryEventsRequest{
executable_backfill_history_events_task.go
123
>
WorkflowKey: e.WorkflowKey,
124
>
SourceClusterName: e.SourceClusterName(),
125
>
VersionedHistory: e.ReplicationTask().VersionedTransition,
126
>
VersionHistoryItems: e.taskAttr.EventVersionHistory,
127
>
Events: events,
128
>
NewEvents: newRunEvents,
129
>
NewRunID: e.taskAttr.NewRunInfo.RunId,
130
>
})
131
132
}