4395
// This is a transient start so no events is being created for it. But we still need to process possible build
4396
// ID redirect.
4397
>
if err := ms.applyActivityBuildIdRedirect(ai, buildId, redirectCounter); err != nil {
mutable_state_impl.go
4398
return nil, err
4399
}
4400
4401
>
if err := ms.UpdateActivity(ai.ScheduledEventId, func(activityInfo *persistencespb.ActivityInfo, _ historyi.MutableState) error {
mutable_state_impl.go
4402
>
// we might need to retry, so do not append started event just yet,
4403
>
// instead update mutable state and will record started event when activity task is closed
4404
>
activityInfo.Version = ms.GetCurrentVersion()
4405
>
activityInfo.StartedEventId = common.TransientEventID
4406
>
activityInfo.StartVersion = ms.GetCurrentVersion()
4407
>
activityInfo.RequestId = requestID
4408
>
activityInfo.StartedTime = timestamppb.New(ms.timeSource.Now())
4409
>
activityInfo.StartedIdentity = identity
4410
>
return nil
4411
>
}); err != nil {
4412
return nil, err
4413
}
4415
>
return nil, nil
4416
}
4417