99
}
100
101
>
resetBranchToken, err := r.getResetBranchToken(ctx, baseBranchToken, baseLastEventID)
resetter.go
102
>
if err != nil {
103
return nil, err
104
}
105
107
>
rebuildMutableState, rebuildStats, err := r.stateRebuilder.Rebuild(
108
>
ctx,
109
>
now,
110
>
definition.NewWorkflowKey(
111
>
r.namespaceID.String(),
112
>
r.workflowID,
113
>
r.baseRunID,
114
>
),
115
>
baseBranchToken,
116
>
baseLastEventID,
117
>
new(baseLastEventVersion),
118
>
definition.NewWorkflowKey(
119
>
r.namespaceID.String(),
120
>
r.workflowID,
121
>
r.newRunID,
122
>
),
123
>
resetBranchToken,
124
>
requestID,
125
>
)
126
>
if err != nil {
127
return nil, err
128
}
130
>
rebuildMutableState.AddExternalPayloadSize(rebuildStats.ExternalPayloadSize)
131
>
rebuildMutableState.AddExternalPayloadCount(rebuildStats.ExternalPayloadCount)
132
>
133
>
if err := rebuildMutableState.RefreshExpirationTimeoutTask(ctx); err != nil {
134
return nil, err
135
}
136
138
>
return rebuildMutableState, nil
139
}
140