Method loadContextualArg

core/modfunc.go:1025–1085

loadContextualArg loads a contextual argument from the module context directory or address. For Directory, it will load the directory from the module context directory. For File, it will load the directory containing the file and then query the file ID from this directory. For Container, it will lo

(
	ctx context.Context,
	dag *dagql.Server,
	arg *FunctionArg,
)

//
// This functions returns the ID of the loaded object.
func (fn *ModuleFunction) loadContextualArg(
	ctx context.Context,
	dag *dagql.Server,
	arg *FunctionArg,
) (dagql.IDType, error) {
	if arg.TypeDef.Self().Kind != TypeDefKindObject {
		return nil, fmt.Errorf("contextual argument %q must be an object", arg.OriginalName)
	}
	if dag == nil {
		return nil, fmt.Errorf("dagql server is nil but required for contextual argument %q", arg.OriginalName)
	}

	// Handle Container types with DefaultAddress
	if arg.DefaultAddress != "" {
		if arg.TypeDef.Self().AsObject.Value.Self().Name != "Container" {
			return nil, fmt.Errorf("defaultAddress can only be used with Container type, not %s", arg.TypeDef.Self().AsObject.Value.Self().Name)
		}
		return loadContainerFromAddress(ctx, dag, arg.DefaultAddress)
	}

	if arg.DefaultPath == "" {
		return nil, fmt.Errorf("argument %q is not a contextual argument", arg.OriginalName)
	}

	// Legacy compat: resolve +defaultPath from workspace root for migrated
	// blueprints/toolchains instead of the module's own source directory.
	if fn.mod.Self().LegacyDefaultPath {
		return fn.loadLegacyDefaultPathArg(ctx, dag, arg)
	}

	switch arg.TypeDef.Self().AsObject.Value.Self().Name {
	case "Directory":
		dir, err := fn.mod.Self().ContextSource.Value.Self().LoadContextDir(ctx, dag, arg.DefaultPath, CopyFilter{
			Exclude: arg.Ignore,
		})
		if err != nil {
			return nil, fmt.Errorf("load contextual directory %q: %w", arg.DefaultPath, err)
		}
		dirID, err := dir.ID()
		if err != nil {
			return nil, fmt.Errorf("get contextual directory ID %q: %w", arg.DefaultPath, err)
		}
		return dagql.NewID[*Directory](dirID), nil

	case "File":
		f, err := fn.mod.Self().ContextSource.Value.Self().LoadContextFile(ctx, dag, arg.DefaultPath)
		if err != nil {
			return nil, fmt.Errorf("load contextual file %q: %w", arg.DefaultPath, err)
		}
		fileID, err := f.ID()
		if err != nil {
			return nil, fmt.Errorf("get contextual file ID %q: %w", arg.DefaultPath, err)
		}
		return dagql.NewID[*File](fileID), nil

	case "GitRepository", "GitRef":
		return fn.loadContextualGitArg(ctx, dag, arg)
	}