92
endpoint, err := ch.endpointRegistry.GetByName(ctx, ns.ID(), attrs.Endpoint)
93
if err != nil {
94
>
if _, ok := errors.AsType[*serviceerror.NotFound](err); ok {
commands.go
95
return chasmworkflow.FailWorkflowTaskError{
96
Cause: enumspb.WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_NEXUS_OPERATION_ATTRIBUTES,
97
Message: fmt.Sprintf("endpoint %q not found", attrs.Endpoint),
98
}
99
>
} else if _, ok := errors.AsType[*serviceerror.PermissionDenied](err); ok {
commands.go
100
return chasmworkflow.FailWorkflowTaskError{
101
Cause: enumspb.WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_NEXUS_OPERATION_ATTRIBUTES,