110
newRunHistory []*historypb.HistoryEvent,
111
newRunID string,
113
>
114
>
if len(history) == 0 {
115
return nil, serviceerror.NewInternal(ErrMessageHistorySizeZero)
116
}
118
>
lastEvent := history[len(history)-1]
119
>
120
>
taskGenerator := GetTaskGeneratorProvider().NewTaskGenerator(b.shard, b.mutableState)
121
>
122
>
// Need to clear the sticky task queue because workflow turned to passive.
123
>
b.mutableState.ClearStickyTaskQueue()
124
>
executionInfo := b.mutableState.GetExecutionInfo()
125
>
executionInfo.LastFirstEventId = firstEvent.GetEventId()
126
>
127
>
// Preserve the WorkflowTaskStamp during rebuild to ensure workflow task validation works correctly.
128
>
// The stamp is used to invalidate stale workflow tasks and must be maintained across rebuilds.
129
>
// Note: The stamp is already persisted in the execution info and should not be reset here.
130
>
131
>
// NOTE: stateRebuilder is also being used in the active side
132
>
if err := b.mutableState.UpdateCurrentVersion(lastEvent.GetVersion(), true); err != nil {
133
return nil, err
134
}
136
>
versionHistory, err := versionhistory.GetCurrentVersionHistory(versionHistories)
137
>
if err != nil {
138
return nil, err
139
}
140
>
if err := versionhistory.AddOrUpdateVersionHistoryItem(versionHistory, versionhistory.NewVersionHistoryItem(
mutable_state_rebuilder.go
141
>
lastEvent.GetEventId(),
142
>
lastEvent.GetVersion(),
143
>
)); err != nil {
144
return nil, err
145
}
147
>
148
>
// [history] is a single persistence batch, so firstEvent.EventId is the batch ID for every
149
>
// event applied below. Event definitions that generate load tokens (e.g. NexusOperationScheduled)
150
>
// read this via GenerateEventLoadToken to find the original batch ID.
151
>
b.mutableState.SetReplayEventBatchID(firstEvent.GetEventId())
152
>
153
>
for _, event := range history {
154
>
switch event.GetEventType() {
155
case enumspb.EVENT_TYPE_WORKFLOW_EXECUTION_STARTED:
156
attributes := event.GetWorkflowExecutionStartedEventAttributes()