Method externalSDKForModule

core/sdk/loader.go:87–122

Load an SDK module from an external source (not builtin to the engine). This will first resolve the path to this SDK module, either from Git or from a local path and load it as a module.

(
	ctx context.Context,
	query *core.Query,
	sdk *core.SDKConfig,
	parentSrc *core.ModuleSource,
)

// This will first resolve the path to this SDK module, either from Git
// or from a local path and load it as a module.
func (l *Loader) externalSDKForModule(
	ctx context.Context,
	query *core.Query,
	sdk *core.SDKConfig,
	parentSrc *core.ModuleSource,
) (core.SDK, error) {
	bk, err := query.Engine(ctx)
	if err != nil {
		return nil, fmt.Errorf("failed to get engine client for sdk %s: %w", sdk.Source, err)
	}
	dag, err := query.Server.Server(ctx)
	if err != nil {
		return nil, fmt.Errorf("failed to get dag for sdk %s: %w", sdk.Source, err)
	}

	sdkModSrc, err := core.ResolveDepToSource(ctx, bk, dag, parentSrc, sdk.Source, "", "")
	if err != nil {
		return nil, err
	}

	if !sdkModSrc.Self().ConfigExists {
		return nil, fmt.Errorf("sdk module source has no dagger.json")
	}

	var sdkMod dagql.ObjectResult[*core.Module]
	err = dag.Select(ctx, sdkModSrc, &sdkMod,
		dagql.Selector{Field: "asModule", Args: []dagql.NamedInput{
			{Name: "forceDefaultFunctionCaching", Value: dagql.Opt(dagql.Boolean(true))},
		}},
	)
	if err != nil {
		return nil, fmt.Errorf("failed to load sdk module %q: %w", sdk.Source, err)
	}

	return newModuleSDK(ctx, query, sdkMod, dagql.ObjectResult[*core.Directory]{}, sdk.Config)
}

func (l *Loader) namedSDK(
	ctx context.Context,