Method loadWorkspaceArg

core/modfunc.go:1257–1283

loadWorkspaceArg loads a workspace argument by resolving it through the currentWorkspace query. The workspace is automatically injected into module functions that declare a Workspace parameter.

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

// currentWorkspace query. The workspace is automatically injected into
// module functions that declare a Workspace parameter.
func (fn *ModuleFunction) loadWorkspaceArg(
	ctx context.Context,
	dag *dagql.Server,
) (dagql.IDType, error) {
	if dag == nil {
		return nil, fmt.Errorf("dagql server is nil but required for workspace argument")
	}

	var ws dagql.ObjectResult[*Workspace]
	err := dag.Select(ctx, dag.Root(), &ws,
		dagql.Selector{
			Field: "currentWorkspace",
			Args: []dagql.NamedInput{
				{Name: "skipMigrationCheck", Value: dagql.Boolean(true)},
			},
		},
	)
	if err != nil {
		return nil, fmt.Errorf("load workspace: %w", err)
	}

	wsID, err := ws.ID()
	if err != nil {
		return nil, fmt.Errorf("get workspace ID: %w", err)
	}
	return dagql.NewID[*Workspace](wsID), nil
}

func (fn *ModuleFunction) applyIgnoreOnDir(ctx context.Context, dag *dagql.Server, arg *FunctionArg, value any) (any, error) {
	if kind := arg.TypeDef.Self().Kind; kind != TypeDefKindObject {