133
return nil, consts.ErrWorkflowCompleted
134
}
135
>
mergeFrom := updateRequest.GetActivityOptions()
api.go
136
>
if mergeFrom == nil {
137
return nil, serviceerror.NewInvalidArgument("ActivityOptions are not provided")
138
}
139
140
>
activityIDs := getActivityIDs(updateRequest, mutableState)
api.go
141
>
142
>
if len(activityIDs) == 0 {
143
return nil, consts.ErrActivityNotFound
144
}
145
146
>
mask := updateRequest.GetUpdateMask()
api.go
147
>
if mask == nil {
148
return nil, serviceerror.NewInvalidArgument("UpdateMask is not provided")
149
}
150
151
>
updateFields := util.ParseFieldMask(mask)
api.go
152
>
153
>
var adjustedOptions *activitypb.ActivityOptions
154
>
var err error
155
>
for _, activityId := range activityIDs {
156
>
ai, activityFound := mutableState.GetActivityByActivityID(activityId)
157
>
158
>
if !activityFound {
159
return nil, consts.ErrActivityNotFound
160
}