Method resolveModuleSourceAsModule

engine/server/session_workspaces.go:833–864

(
	ctx context.Context,
	dag *dagql.Server,
	src dagql.ObjectResult[*core.ModuleSource],
	mod pendingModule,
)

}

func (srv *Server) resolveModuleSourceAsModule(
	ctx context.Context,
	dag *dagql.Server,
	src dagql.ObjectResult[*core.ModuleSource],
	mod pendingModule,
) (dagql.ObjectResult[*core.Module], error) {
	if mod.Ref == "" && src.Self() != nil {
		mod.Ref = src.Self().AsString()
	}
	if mod.RefPin == "" && src.Self() != nil {
		mod.RefPin = src.Self().Pin()
	}
	if mod.LegacyCallerModuleDir != "" && mod.Entrypoint {
		if err := srv.mergeLegacyCallerEnvDefaults(ctx, dag, src.Self(), mod.LegacyCallerModuleDir); err != nil {
			return dagql.ObjectResult[*core.Module]{}, err
		}
	}

	asModuleArgs, err := asModuleArgsForPendingModule(mod)
	if err != nil {
		return dagql.ObjectResult[*core.Module]{}, err
	}

	var resolved dagql.ObjectResult[*core.Module]
	err = dag.Select(ctx, src, &resolved,
		dagql.Selector{Field: "asModule", Args: asModuleArgs},
	)
	if err != nil {
		return dagql.ObjectResult[*core.Module]{}, err
	}
	return resolved, nil
}

func asModuleArgsForPendingModule(mod pendingModule) ([]dagql.NamedInput, error) {
	// Delegates to the shared builder so the workspace entrypoint path and the