426
scheduleNewRun bool,
427
jitter time.Duration,
428
>
) (*historyservice.UnpauseActivityResponse, error) {
activity.go
429
>
430
>
if err := mutableState.UpdateActivity(ai.ScheduledEventId, func(activityInfo *persistencespb.ActivityInfo, ms historyi.MutableState) error {
431
>
unpauseActivityInfo(activityInfo)
432
>
433
>
// regenerate the retry task if needed
434
>
if GetActivityState(ai) == enumspb.PENDING_ACTIVITY_STATE_SCHEDULED {
435
>
if err := regenerateActivityRetryTask(activityInfo, scheduleNewRun, jitter, ms, shardContext); err != nil {
436
return err
437
}
438
}
440
}); err != nil {
441
return nil, err
442
}
443
444
>
return &historyservice.UnpauseActivityResponse{}, nil
activity.go
445
}
446