|
Download docs/open_mythos.md from Jessedbrown/OpenMythos: direct link, hf CLI and curl.
- Browser
- Download file 20.4 kB
-
https://huggingface.co/Jessedbrown/OpenMythos/resolve/main/docs/open_mythos.md
- Command line
-
hf download hf://Jessedbrown/OpenMythos/docs/open_mythos.md
-
curl -L -o open_mythos.md https://huggingface.co/Jessedbrown/OpenMythos/resolve/main/docs/open_mythos.md
20.4 kB
| # `OpenMythos` β Class Reference | |
| **Module:** `open_mythos.main` | |
| **Base class:** `torch.nn.Module` | |
| --- | |
| ## Overview | |
| `OpenMythos` is the top-level model class implementing the Recurrent-Depth Transformer (RDT) architecture described in [the OpenMythos hypothesis](../README.md). It assembles three functional stages β **Prelude**, **Recurrent Block**, and **Coda** β into a complete autoregressive language model. | |
| ``` | |
| Input token IDs (B, T) | |
| β | |
| [Embedding] token index β dim-dimensional vector | |
| β | |
| [Prelude] prelude_layers Γ standard TransformerBlock (run once) | |
| β | |
| [Recurrent Block] one TransformerBlock looped T times | |
| β___________β h_{t+1} = AΒ·h_t + BΒ·e + Transformer(h_t, e) | |
| β | |
| [Coda] coda_layers Γ standard TransformerBlock (run once) | |
| β | |
| [RMSNorm β LM head] | |
| β | |
| Output logits (B, T, vocab_size) | |
| ``` | |
| Every architectural choice in `OpenMythos` can be configured through a single [`MythosConfig`](#mythosconfig) dataclass passed at construction. | |
| --- | |
| ## `MythosConfig` | |
| ```python | |
| @dataclass | |
| class MythosConfig | |
| ``` | |
| All hyperparameters for the model are stored in this single frozen-style dataclass. Pass an instance to `OpenMythos.__init__`. | |
| ### Core fields | |
| | Field | Type | Default | Description | | |
| |---|---|---|---| | |
| | `vocab_size` | `int` | `32000` | Token vocabulary size; sets the embedding and LM head dimension | | |
| | `dim` | `int` | `2048` | Model hidden dimension β the width of the residual stream throughout | | |
| | `n_heads` | `int` | `16` | Number of query attention heads | | |
| | `n_kv_heads` | `int` | `4` | Number of key/value heads (GQA only); `n_heads // n_kv_heads` Q heads share each KV pair | | |
| | `max_seq_len` | `int` | `4096` | Maximum sequence length; RoPE frequencies are precomputed up to this length | | |
| | `max_loop_iters` | `int` | `16` | Default recurrent loop depth T at inference. Can be overridden per call | | |
| | `prelude_layers` | `int` | `2` | Number of standard transformer blocks run once before the recurrent loop | | |
| | `coda_layers` | `int` | `2` | Number of standard transformer blocks run once after the recurrent loop | | |
| ### Attention fields | |
| `attn_type` selects between two complete attention implementations. All other attention fields are implementation-specific. | |
| | Field | Type | Default | Description | | |
| |---|---|---|---| | |
| | `attn_type` | `str` | `"mla"` | `"gqa"` for Grouped Query Attention; `"mla"` for Multi-Latent Attention | | |
| | `kv_lora_rank` | `int` | `512` | **[MLA only]** Compressed KV latent rank stored in the cache instead of full K and V | | |
| | `q_lora_rank` | `int` | `1536` | **[MLA only]** Compressed Q latent rank | | |
| | `qk_rope_head_dim` | `int` | `64` | **[MLA only]** Per-head dimension receiving RoPE positional encoding | | |
| | `qk_nope_head_dim` | `int` | `128` | **[MLA only]** Per-head dimension without positional encoding | | |
| | `v_head_dim` | `int` | `128` | **[MLA only]** Per-head value dimension | | |
| **GQA vs MLA:** GQA reduces KV cache by having fewer KV heads than Q heads (factor of `n_heads / n_kv_heads`). MLA achieves a much larger reduction by caching a low-rank KV latent (`kv_lora_rank`) and the RoPE keys (`n_heads Γ qk_rope_head_dim`), then reconstructing full K and V on the fly. At production scale MLA yields roughly 10β20Γ smaller KV cache than standard attention. | |
| ### MoE FFN fields | |
| The Mixture-of-Experts FFN is used exclusively inside the Recurrent Block. Prelude and Coda use a dense SwiGLU FFN. | |
| | Field | Type | Default | Description | | |
| |---|---|---|---| | |
| | `n_experts` | `int` | `64` | Total number of routed expert FFNs | | |
| | `n_shared_experts` | `int` | `2` | Always-active shared experts; absorb common cross-domain patterns | | |
| | `n_experts_per_tok` | `int` | `4` | Top-K routed experts selected per token by the router | | |
| | `expert_dim` | `int` | `512` | Hidden dimension inside each fine-grained routed expert | | |
| Approximately `n_experts_per_tok / n_experts = 6.25%` of routed expert parameters are activated per token, plus all shared expert parameters. | |
| ### Stability and adaptation fields | |
| | Field | Type | Default | Description | | |
| |---|---|---|---| | |
| | `act_threshold` | `float` | `0.99` | ACT cumulative halting threshold; loop exits per-position once this is exceeded | | |
| | `rope_theta` | `float` | `500000.0` | RoPE base frequency (LLaMA-3 default; higher = slower frequency decay over sequence positions) | | |
| | `lora_rank` | `int` | `16` | Rank of the depth-wise LoRA adapter applied inside each loop iteration | | |
| --- | |
| ## Constructor | |
| ```python | |
| OpenMythos(cfg: MythosConfig) | |
| ``` | |
| Builds all sub-modules, precomputes RoPE frequency buffers, and runs weight initialization. | |
| **What happens internally:** | |
| 1. `nn.Embedding(vocab_size, dim)` β token embedding table, weight-tied with the LM head. | |
| 2. RoPE buffers β `freqs_cis` (for GQA, dim = `dim // n_heads`) and `freqs_cis_mla` (for MLA, dim = `qk_rope_head_dim`) are precomputed once and registered as non-parameter buffers. The correct buffer is selected at forward time based on `cfg.attn_type`. | |
| 3. `prelude` β `nn.ModuleList` of `prelude_layers` `TransformerBlock` instances with dense SwiGLU FFN. | |
| 4. `recurrent` β a single `RecurrentBlock` containing one `TransformerBlock` (with MoE FFN), `LTIInjection`, `ACTHalting`, and `LoRAAdapter`. | |
| 5. `coda` β `nn.ModuleList` of `coda_layers` `TransformerBlock` instances with dense SwiGLU FFN. | |
| 6. `RMSNorm(dim)` applied before the LM head. | |
| 7. `nn.Linear(dim, vocab_size, bias=False)` LM head with weights tied to the embedding. | |
| 8. All `nn.Linear` and `nn.Embedding` weights initialized from N(0, 0.02). | |
| **Example:** | |
| ```python | |
| from open_mythos.main import OpenMythos, MythosConfig | |
| cfg = MythosConfig( | |
| vocab_size=32000, | |
| dim=2048, | |
| n_heads=16, | |
| n_kv_heads=4, | |
| max_loop_iters=16, | |
| attn_type="mla", | |
| ) | |
| model = OpenMythos(cfg) | |
| print(f"Parameters: {sum(p.numel() for p in model.parameters()):,}") | |
| ``` | |
| --- | |
| ## `forward` | |
| ```python | |
| def forward( | |
| self, | |
| input_ids: torch.Tensor, | |
| n_loops: Optional[int] = None, | |
| kv_cache: Optional[dict] = None, | |
| ) -> torch.Tensor | |
| ``` | |
| Single forward pass through the full Prelude β Recurrent Block β Coda pipeline. | |
| ### Parameters | |
| | Parameter | Type | Description | | |
| |---|---|---| | |
| | `input_ids` | `Tensor (B, T)` | Batch of token index sequences. `B` = batch size, `T` = sequence length | | |
| | `n_loops` | `int \| None` | Recurrent loop depth for this call. Defaults to `cfg.max_loop_iters`. Pass a higher value at inference to extrapolate to harder problems (depth extrapolation property). | | |
| | `kv_cache` | `dict \| None` | If provided, keys and values are accumulated here for autoregressive decoding. Pass `{}` on the first decode step and reuse the same dict across steps. Pass `None` for training or full-context inference. | | |
| ### Returns | |
| `Tensor (B, T, vocab_size)` β raw (unnormalized) logits over the vocabulary for each position. | |
| ### Behavior walkthrough | |
| ``` | |
| 1. Embed: x = embedding(input_ids) # (B, T, dim) | |
| 2. Select RoPE buffer: | |
| if attn_type == "mla": use freqs_cis_mla[:T] | |
| else: use freqs_cis[:T] | |
| 3. Build causal mask (upper-triangular -inf): | |
| if T > 1: mask = _causal_mask(T, device) | |
| else: mask = None (single-token decode step) | |
| 4. Prelude: | |
| for i, layer in prelude: | |
| x = layer(x, freqs_cis, mask, kv_cache, f"prelude_{i}") | |
| 5. Freeze encoded input: | |
| e = x # (B, T, dim) | |
| 6. Recurrent loop: | |
| x = recurrent(x, e, freqs_cis, mask, n_loops, kv_cache) | |
| 7. Coda: | |
| for i, layer in coda: | |
| x = layer(x, freqs_cis, mask, kv_cache, f"coda_{i}") | |
| 8. Project: logits = lm_head(norm(x)) # (B, T, vocab_size) | |
| ``` | |
| **Step 5 (freeze `e`)** is the key architectural invariant: the encoded input `e` is captured after the Prelude and injected at *every* loop iteration unchanged. This prevents the hidden state from drifting away from the original input signal regardless of loop depth. | |
| ### Training example | |
| ```python | |
| import torch | |
| from open_mythos.main import OpenMythos, MythosConfig | |
| model = OpenMythos(MythosConfig()).cuda() | |
| optimizer = torch.optim.AdamW(model.parameters(), lr=3e-4) | |
| input_ids = torch.randint(0, 32000, (2, 512)).cuda() | |
| labels = torch.randint(0, 32000, (2, 512)).cuda() | |
| logits = model(input_ids) # (2, 512, 32000) | |
| loss = torch.nn.functional.cross_entropy( | |
| logits.view(-1, 32000), | |
| labels.view(-1), | |
| ) | |
| loss.backward() | |
| optimizer.step() | |
| ``` | |
| ### Depth extrapolation at inference | |
| A looped transformer trained on `N` loops can be evaluated on `N + k` loops and often achieves higher quality on hard multi-hop problems. Pass `n_loops` at inference time: | |
| ```python | |
| # Trained with max_loop_iters=16 β try deeper reasoning at test time | |
| logits_deep = model(input_ids, n_loops=32) | |
| ``` | |
| --- | |
| ## `generate` | |
| ```python | |
| @torch.no_grad() | |
| def generate( | |
| self, | |
| input_ids: torch.Tensor, | |
| max_new_tokens: int = 64, | |
| n_loops: int = 8, | |
| temperature: float = 1.0, | |
| top_k: int = 50, | |
| ) -> torch.Tensor | |
| ``` | |
| Autoregressive token generation with KV caching. Processes the full prompt on step 0, then decodes one token at a time using the accumulated cache. | |
| ### Parameters | |
| | Parameter | Type | Default | Description | | |
| |---|---|---|---| | |
| | `input_ids` | `Tensor (B, T)` | β | Prompt token indices | | |
| | `max_new_tokens` | `int` | `64` | Number of new tokens to generate | | |
| | `n_loops` | `int` | `8` | Recurrent loop depth per decode step. Can be higher than the training value for harder prompts (depth extrapolation) | | |
| | `temperature` | `float` | `1.0` | Softmax temperature applied to logits before sampling. Values < 1 make the distribution more peaked (less random); values > 1 make it flatter | | |
| | `top_k` | `int` | `50` | Restricts sampling to the top-K most probable tokens at each step. `0` disables filtering (full vocabulary sampling) | | |
| ### Returns | |
| `Tensor (B, T + max_new_tokens)` β the original prompt concatenated with the generated token indices. | |
| ### KV caching mechanism | |
| On step 0, the full prompt `(B, T)` is passed and all keys/values for every layer are populated in `kv_cache`. On steps 1β¦N only the single most recent token `(B, 1)` is passed; the attention layers read back all prior K/V from the cache. This makes decode cost proportional to a single token per step rather than the full growing sequence. | |
| Each layer caches under a deterministic string key (`"prelude_0"`, `"recurrent_loop_3"`, `"coda_1"`, etc.), so caches from different layers never collide. | |
| ### Sampling strategy | |
| ``` | |
| logits = forward(cur_ids, n_loops, kv_cache)[:, -1, :] / temperature | |
| if top_k > 0: | |
| threshold = logits.topk(top_k).values[:, -1:] | |
| logits[logits < threshold] = -inf | |
| probs = softmax(logits) | |
| next_tok = multinomial(probs, num_samples=1) | |
| ``` | |
| ### Generation example | |
| ```python | |
| import torch | |
| from open_mythos.main import OpenMythos, MythosConfig | |
| model = OpenMythos(MythosConfig()).eval() | |
| # Tokenized prompt (use your tokenizer of choice) | |
| prompt = torch.tensor([[1, 450, 3118, 310, 278]]) # (1, 5) | |
| output = model.generate( | |
| prompt, | |
| max_new_tokens=128, | |
| n_loops=16, # deeper reasoning | |
| temperature=0.8, | |
| top_k=40, | |
| ) | |
| # output.shape == (1, 133) | |
| ``` | |
| --- | |
| ## Internal Components | |
| The following sub-modules are assembled inside `OpenMythos`. They are not typically called directly but understanding them clarifies the model's behavior. | |
| ### `RecurrentBlock` | |
| The heart of the architecture. A single `TransformerBlock` (with MoE FFN) is run in a loop for up to `n_loops` iterations, with the following per-iteration pipeline: | |
| ``` | |
| h_loop = loop_index_embedding(h, t, loop_dim) # inject sinusoidal loop-index signal | |
| combined = RMSNorm(h_loop + e) # add frozen encoded input | |
| trans_out = TransformerBlock(combined, ...) # attention + MoE FFN | |
| trans_out = trans_out + LoRAAdapter(trans_out, t) # depth-wise LoRA delta | |
| h = LTIInjection(h, e, trans_out) # stable update: AΒ·h + BΒ·e + trans_out | |
| p = ACTHalting(h) # per-position halting probability | |
| ``` | |
| The loop exits early for positions whose cumulative halting probability exceeds `cfg.act_threshold`. If all positions have halted, the loop exits before `n_loops`. The final output is an ACT-weighted sum of `h` across iterations. | |
| ### `LTIInjection` | |
| Implements the stable recurrent update rule `h_{t+1} = AΒ·h_t + BΒ·e + transformer_out`. The diagonal matrix `A` is parameterized as: | |
| ``` | |
| A_continuous = Diag(-exp(log_A)) # always negative diagonal | |
| A_discrete = exp(Ξt Β· A_continuous) # ZOH discretization, values β (0, 1) | |
| ``` | |
| This guarantees spectral radius `Ο(A) < 1` by construction, making the looped model unconditionally stable regardless of learning rate or batch noise. See [Parcae (Prairie et al., 2026)](https://arxiv.org/abs/2604.12946) for the theoretical foundation. | |
| ### `ACTHalting` | |
| A single linear layer mapping `(B, T, dim) β (B, T)` followed by sigmoid. At each loop step, the scalar halting probability per position is accumulated. When the cumulative sum exceeds `cfg.act_threshold`, the ACT remainder trick assigns the remaining probability mass as the final weight and the position stops contributing. Implements Graves (2016) ACT. | |
| ### `LoRAAdapter` | |
| A depth-wise low-rank adapter with three components: | |
| - `down`: shared `Linear(dim, rank)` β down-projects the transformer output | |
| - `B`: shared parameter matrix `(rank, dim)` β up-projects back to full dimension | |
| - `scale`: `Embedding(max_loops, rank)` β per-loop element-wise scale | |
| The delta per iteration is `(down(x) * scale[t]) @ B`. Bridges the expressiveness gap between pure weight-tying and fully distinct per-layer weights. Based on [Relaxed Recursive Transformers (Bae et al., 2024)](https://arxiv.org/pdf/2410.20672). | |
| ### `TransformerBlock` | |
| Pre-norm transformer block with swappable attention and FFN: | |
| - **Attention:** `MLAttention` (MLA) or `GQAttention` (GQA), selected by `cfg.attn_type` | |
| - **FFN:** `MoEFFN` (when `use_moe=True`, inside `RecurrentBlock`) or dense `Expert` (Prelude, Coda) | |
| - Pre-norm via `RMSNorm` applied to both the attention input and FFN input | |
| ### `MLAttention` | |
| Multi-Latent Attention ([DeepSeek-V2, 2024](https://arxiv.org/abs/2405.04434)). The cache stores only the compressed KV latent `c_kv` (rank `kv_lora_rank`) plus the RoPE-encoded keys. At each decode step, `K_nope` and `V` are cheaply reconstructed from `c_kv` via a shared up-projection, trading a fast linear multiply for dramatically smaller KV memory footprint. | |
| Cache size per layer per token: `kv_lora_rank + n_heads Γ qk_rope_head_dim` vs. full GQA cache of `n_kv_heads Γ head_dim Γ 2`. | |
| ### `GQAttention` | |
| Grouped Query Attention ([Ainslie et al., 2023](https://arxiv.org/abs/2305.13245)). `n_kv_heads` KV pairs are shared across `n_heads // n_kv_heads` query heads each, reducing KV cache by that factor while preserving full query expressiveness. | |
| ### `MoEFFN` | |
| Fine-grained Mixture-of-Experts FFN ([DeepSeekMoE, Dai et al., 2024](https://arxiv.org/abs/2401.06066)): | |
| - **Routed experts:** `n_experts` small SwiGLU FFNs. Each token's router selects the top-`n_experts_per_tok` via softmax over learned logits. A per-expert bias `router_bias` (non-gradient, updated externally) keeps load balanced. | |
| - **Shared experts:** `n_shared_experts` always-active FFNs with width `expert_dim Γ n_experts_per_tok`, absorbing cross-domain patterns. | |
| Total activated parameters per token: `(n_experts_per_tok / n_experts)` of routed capacity + all shared capacity. | |
| ### `Expert` | |
| Single SwiGLU feed-forward unit: `down(silu(gate(x)) * up(x))`. Used both as individual routed experts inside `MoEFFN` and as the dense FFN in Prelude/Coda blocks. | |
| ### `RMSNorm` | |
| Root Mean Square Layer Normalization ([Zhang & Sennrich, 2019](https://arxiv.org/abs/1910.07467)). Normalizes by `x / rms(x)` with a learned per-channel rescaling weight. No bias, no mean subtraction. Used throughout in place of standard LayerNorm. | |
| --- | |
| ## Utility functions | |
| ### `precompute_rope_freqs(dim, max_len, theta)` | |
| Precomputes complex-valued RoPE rotation matrices as a `(max_len, dim//2)` complex64 tensor. Called once in `__init__` and stored as a buffer. | |
| ### `apply_rope(x, freqs_cis)` | |
| Applies precomputed RoPE frequencies to a query or key tensor by treating adjacent feature pairs as complex numbers and multiplying pointwise by the positional phasor. | |
| ### `loop_index_embedding(h, loop_t, loop_dim, theta)` | |
| Injects a sinusoidal loop-index signal into the first `loop_dim` channels of the hidden state, analogous to RoPE but over recurrence depth rather than sequence position. Allows the shared recurrent block weights to behave differently at different loop iterations. | |
| --- | |
| ## Key design properties | |
| | Property | Mechanism | Benefit | | |
| |---|---|---| | |
| | Depth extrapolation | Recurrent block with looped identical weights | Train on N loops, test on N+k β harder problems solved without retraining | | |
| | Parameter efficiency | Weight sharing across all loop iterations | k-layer model achieves quality of kL-layer model; parameters β k, compute β L | | |
| | Adaptive compute | ACT halting per position | Easy tokens exit early; hard tokens receive full loop depth β within the same batch | | |
| | Stable training | LTI injection with ZOH-constrained A (Ο(A) < 1) | No residual explosion; robust to high learning rates | | |
| | Domain breadth | MoE FFN in recurrent block | Different expert subsets can be routed to at each loop depth | | |
| | Loop differentiation | Loop-index sinusoidal embedding | Same weights implement functionally distinct phases per iteration | | |
| | Efficient KV memory | MLA (default) or GQA | MLA: 10β20Γ smaller cache vs standard attention at production scale | | |
| | Depth-wise adaptation | LoRA adapter per loop iteration | Expressiveness beyond pure weight-tying; minimal parameter overhead | | |
| --- | |
| ## Full configuration reference | |
| The default `MythosConfig()` targets a mid-scale research model. Below is a minimal configuration for quick experimentation: | |
| ```python | |
| from open_mythos.main import OpenMythos, MythosConfig | |
| # Minimal config for fast iteration / unit testing | |
| small_cfg = MythosConfig( | |
| vocab_size=8192, | |
| dim=256, | |
| n_heads=4, | |
| n_kv_heads=2, | |
| max_seq_len=512, | |
| max_loop_iters=4, | |
| prelude_layers=1, | |
| coda_layers=1, | |
| attn_type="gqa", | |
| n_experts=8, | |
| n_shared_experts=1, | |
| n_experts_per_tok=2, | |
| expert_dim=64, | |
| lora_rank=4, | |
| ) | |
| model = OpenMythos(small_cfg) | |
| ``` | |
| And a production-oriented MLA configuration matching the default hyperparameters: | |
| ```python | |
| # Default MLA config (matches MythosConfig() defaults) | |
| prod_cfg = MythosConfig( | |
| vocab_size=32000, | |
| dim=2048, | |
| n_heads=16, | |
| n_kv_heads=4, | |
| max_seq_len=4096, | |
| max_loop_iters=16, | |
| prelude_layers=2, | |
| coda_layers=2, | |
| attn_type="mla", # Multi-Latent Attention | |
| kv_lora_rank=512, | |
| q_lora_rank=1536, | |
| qk_rope_head_dim=64, | |
| qk_nope_head_dim=128, | |
| v_head_dim=128, | |
| n_experts=64, | |
| n_shared_experts=2, | |
| n_experts_per_tok=4, | |
| expert_dim=512, | |
| act_threshold=0.99, | |
| rope_theta=500000.0, | |
| lora_rank=16, | |
| ) | |
| model = OpenMythos(prod_cfg) | |
| ``` | |
| --- | |
| ## References | |
| | Component | Paper | | |
| |---|---| | |
| | Recurrent-Depth Transformer | [Loop, Think, & Generalize (2025)](https://arxiv.org/pdf/2604.07822) | | |
| | LTI-stable injection (Parcae) | [Scaling Laws for Stable Looped Language Models (Prairie et al., 2026)](https://arxiv.org/abs/2604.12946) | | |
| | Looped transformer reasoning | [Reasoning with Latent Thoughts (Saunshi et al., 2025)](https://arxiv.org/abs/2502.17416) | | |
| | Multi-Latent Attention | [DeepSeek-V2 (2024)](https://arxiv.org/abs/2405.04434) | | |
| | Grouped Query Attention | [Ainslie et al., 2023](https://arxiv.org/abs/2305.13245) | | |
| | Mixture-of-Experts FFN | [DeepSeekMoE (Dai et al., 2024)](https://arxiv.org/abs/2401.06066) | | |
| | Adaptive Computation Time | [Graves, 2016](https://arxiv.org/abs/1603.08983) | | |
| | Depth-wise LoRA | [Relaxed Recursive Transformers (Bae et al., 2024)](https://arxiv.org/pdf/2410.20672) | | |
| | RMSNorm | [Zhang & Sennrich, 2019](https://arxiv.org/abs/1910.07467) | | |
| | RoPE | [Su et al., 2021](https://arxiv.org/abs/2104.09864) | | |
| | Universal Transformer (ACT basis) | [Dehghani et al., 2018](https://arxiv.org/pdf/1807.03819) | | |
| | Continuous latent reasoning | [COCONUT (2024)](https://arxiv.org/abs/2412.06769) | | |