61
}
62
// Run ProcessInput for validation.
63
>
_, err := ch.nexusProcessor.ProcessInput(chasm.NexusOperationProcessorContext{
commands.go
64
>
Namespace: ns,
65
>
RequestID: requestID,
66
>
// Links are not needed for validation.
67
>
}, attrs.Service, attrs.Operation, attrs.Input)
68
>
if err != nil {
69
>
_, isNotFound := errors.AsType[*serviceerror.NotFound](err)
70
>
_, isInvalidArgument := errors.AsType[*serviceerror.InvalidArgument](err)
71
>
if isNotFound || isInvalidArgument {
72
return chasmworkflow.FailWorkflowTaskError{
73
Cause: enumspb.WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_NEXUS_OPERATION_ATTRIBUTES,