707
endpoint, err = e.lookupEndpoint(ctx, namespace.ID(ref.WorkflowKey.NamespaceID), args.endpointID, args.endpointName)
708
if err != nil {
709
>
if errors.As(err, new(*serviceerror.NotFound)) {
executors.go
710
>
handlerError := nexus.NewHandlerErrorf(nexus.HandlerErrorTypeNotFound, "endpoint not registered")
711
>
712
>
// The endpoint is not registered, immediately fail the invocation.
713
>
return e.saveCancelationResult(ctx, env, ref, handlerError, args.scheduledEventID)
714
>
}
715
return err
716
}