3214
reason string,
3215
requestID string,
3217
>
opTag := tag.WorkflowActionWorkflowPaused
3218
>
if err := ms.checkMutability(opTag); err != nil {
3219
return nil, err
3220
}
3221
>
event := ms.hBuilder.AddWorkflowExecutionPausedEvent(identity, reason, requestID)
mutable_state_impl.go
3222
>
if err := ms.ApplyWorkflowExecutionPausedEvent(event); err != nil {
3223
return nil, err
3224
}
3226
}
3227
3228
// ApplyWorkflowExecutionPausedEvent applies the paused event to the mutable state. It updates the workflow execution status to paused and sets the pause info.
3229
>
func (ms *MutableStateImpl) ApplyWorkflowExecutionPausedEvent(event *historypb.HistoryEvent) error {
mutable_state_impl.go
3230
>
// Update workflow status.
3231
>
if _, err := ms.UpdateWorkflowStateStatus(ms.executionState.GetState(), enumspb.WORKFLOW_EXECUTION_STATUS_PAUSED); err != nil {
3232
return err
3233
}
3234
// Set pause info in mutable state.
3236
>
PauseTime: timestamppb.New(event.GetEventTime().AsTime()),
3237
>
Identity: event.GetWorkflowExecutionPausedEventAttributes().GetIdentity(),
3238
>
Reason: event.GetWorkflowExecutionPausedEventAttributes().GetReason(),
3239
>
RequestId: event.GetWorkflowExecutionPausedEventAttributes().GetRequestId(),
3240
>
}
3241
>
3242
>
// Update approximate size of the mutable state. This will be decreased when the pause info is removed (when the workflow is unpaused)
3243
>
ms.approximateSize += ms.executionInfo.PauseInfo.Size()
3244
>
3245
>
// Invalidate all the pending activities. Do not mark individual activities as paused.
3246
>
for _, ai := range ms.GetPendingActivityInfos() {
3247
if err := ms.UpdateActivity(ai.ScheduledEventId, func(activityInfo *persistencespb.ActivityInfo, _ historyi.MutableState) error {
3248
activityInfo.Stamp = activityInfo.Stamp + 1