24
shard historyi.ShardContext,
25
workflowConsistencyChecker api.WorkflowConsistencyChecker,
26
>
) (resp *historyservice.RespondActivityTaskCanceledResponse, retError error) {
api.go
27
>
request := req.CancelRequest
28
>
tokenSerializer := tasktoken.NewSerializer()
29
>
token, err0 := tokenSerializer.Deserialize(request.TaskToken)
30
>
if err0 != nil {
31
return nil, consts.ErrDeserializingToken
32
}
33
34
>
namespaceEntry, err := api.GetActiveNamespace(shard, namespace.ID(req.GetNamespaceId()), token.WorkflowId)
api.go
35
>
if err != nil {
36
return nil, err
37
}
38
>
namespaceName := namespaceEntry.Name()
api.go
39
>
if err := api.SetActivityTaskRunID(ctx, token, workflowConsistencyChecker); err != nil {
40
return nil, err
41
}