324
ms historyi.MutableState,
325
updateRequest *workflowservice.UpdateActivityOptionsRequest,
326
>
) (*historyservice.UpdateActivityOptionsResponse, error) {
api.go
327
>
328
>
activityIDs := getActivityIDs(updateRequest, ms)
329
>
330
>
if len(activityIDs) == 0 {
331
return nil, consts.ErrActivityNotFound
332
}
333
334
>
var updatedOptions *activitypb.ActivityOptions
api.go
335
>
336
>
for _, activityId := range activityIDs {
337
>
ai, activityFound := ms.GetActivityByActivityID(activityId)
338
>
339
>
if !activityFound {
340
return nil, consts.ErrActivityNotFound
341
}
342
343
>
event, err := ms.GetActivityScheduledEvent(ctx, ai.ScheduledEventId)
api.go
344
>
if err != nil {
345
return nil, err
346
}