697
// Skip endpoint lookup for system-internal operations.
698
if args.endpointName != commonnexus.SystemEndpoint {
699
>
// This happens when we accept the ScheduleNexusOperation command when the endpoint is not found in the registry as
executors.go
700
>
// indicated by the EndpointNotFoundAlwaysNonRetryable dynamic config.
701
>
// The config has been removed but we keep this check for backward compatibility.
702
>
if args.endpointID == "" {
703
handlerError := nexus.NewHandlerErrorf(nexus.HandlerErrorTypeNotFound, "endpoint not registered")
704
return e.saveCancelationResult(ctx, env, ref, handlerError, args.scheduledEventID)
705
}
706
707
>
endpoint, err = e.lookupEndpoint(ctx, namespace.ID(ref.WorkflowKey.NamespaceID), args.endpointID, args.endpointName)
executors.go
708
>
if err != nil {
709
if errors.As(err, new(*serviceerror.NotFound)) {
710
handlerError := nexus.NewHandlerErrorf(nexus.HandlerErrorTypeNotFound, "endpoint not registered")