Method resolveModule

engine/server/session_workspaces.go:983–1012

resolveModule resolves a module through the dagql pipeline. Handles all module sources uniformly: legacy compat modules, implicit CWD modules, and -m flag modules. Legacy settings (LegacyDefaultPath, ArgCustomizations, WorkspaceConfig, etc.) are passed as internal args to asModule so they are appli

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

// is installed into dagql — mutating the result after Select is incorrect because
// dagql may return a cached (and already-installed) pointer.
func (srv *Server) resolveModule(
	ctx context.Context,
	dag *dagql.Server,
	mod pendingModule,
) (dagql.ObjectResult[*core.Module], error) {
	srcArgs := []dagql.NamedInput{
		{Name: "refString", Value: dagql.String(mod.Ref)},
	}
	if mod.RefPin != "" {
		srcArgs = append(srcArgs, dagql.NamedInput{Name: "refPin", Value: dagql.String(mod.RefPin)})
	}
	if mod.DisableFindUp {
		srcArgs = append(srcArgs, dagql.NamedInput{Name: "disableFindUp", Value: dagql.Boolean(true)})
	}

	var src dagql.ObjectResult[*core.ModuleSource]
	err := dag.Select(ctx, dag.Root(), &src,
		dagql.Selector{Field: "moduleSource", Args: srcArgs},
	)
	if err != nil {
		return dagql.ObjectResult[*core.Module]{}, fmt.Errorf("resolving module source %q: %w", mod.Ref, err)
	}

	resolved, err := srv.resolveModuleSourceAsModule(ctx, dag, src, mod)
	if err != nil {
		return dagql.ObjectResult[*core.Module]{}, fmt.Errorf("resolving module source %q: %w", mod.Ref, err)
	}

	return resolved, nil
}

func (srv *Server) mergeLegacyCallerEnvDefaults(
	ctx context.Context,