671
_ context.Context,
672
attr *commandpb.RequestCancelActivityTaskCommandAttributes,
674
>
if err := handler.validateCommandAttr(
675
>
func() (enumspb.WorkflowTaskFailedCause, error) {
676
>
return handler.attrValidator.ValidateActivityCancelAttributes(attr)
677
>
},
678
); err != nil || handler.stopProcessing {
679
return nil, err
680
}
681
683
>
actCancelReqEvent, ai, err := handler.mutableState.AddActivityTaskCancelRequestedEvent(
684
>
handler.workflowTaskCompletedID,
685
>
scheduledEventID,
686
>
handler.identity,
687
>
)
688
>
if err != nil {
689
return nil, handler.failWorkflowTaskOnInvalidArgument(enumspb.WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES, err)
690
}