112
ctx context.Context,
113
req *historyservice.RespondWorkflowTaskCompletedRequest,
114
>
) (_ *historyservice.RespondWorkflowTaskCompletedResponse, retError error) {
api.go
115
>
// By default, retError is passed to workflow lease release method in deferred function.
116
>
// If error is passed, then workflow context and mutable state are cleared.
117
>
// If no changes to mutable state are made or changes already persisted (in memory version corresponds to the database),
118
>
// then the lease is released without an error, i.e. workflow context and mutable state are NOT cleared.
119
>
releaseLeaseWithError := true
120
>
121
>
request := req.CompleteRequest
122
>
token, err0 := handler.tokenSerializer.Deserialize(request.TaskToken)
123
>
if err0 != nil {
124
return nil, consts.ErrDeserializingToken
125
}