Detect cleared parameters on the fast path and tighten the parity tolerance - #87
Merged
Merged
Conversation
`del module.weight`, `linear.bias = None` and direct writes to a module's `_parameters`, `_buffers` or `_modules` fire none of torch's global registration hooks, so after the first validated call the unchecked path kept running (a layer silently without its bias) until a new signature, a move or cast, or a failing layer forced a full check. Each graph now records every module's three stores together with a copy of each whenever its state is found to match the build, and every call compares the two tuples in one C-level comparison: values are compared by identity first, so an unchanged store costs about 10-17 ns and never touches its tensors. A mismatch takes the validating path, which reports removed or added state with the usual E_RUNTIME naming the node and the change, and re-checks every port when a tensor was swapped in under the same name. .to()/casts drop the recorded copies so replaced tensors are released immediately. torch.compile tracing is unchanged: the compiling path returns before the comparison. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
Sixteen runs of the opt-in benchmark suite with the registered-state comparison in place measured mlp 1.00-1.13x, conv_stack 0.97-1.17x and transformer_block 1.10-1.24x of hand-written PyTorch. 1.5x leaves about 20% over the worst of those. The docstring records the runs, the machine, and the one noisy conv_stack reading (1.91x, on the code before this branch) that a loaded machine can produce. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
The per-call store check compared copies of every _parameters/_buffers dict with ==, so a tensor swapped in under its name (functional_call) ran an elementwise Tensor.__eq__ and a full re-check on every call, kept the swapped tensors and their autograd graphs alive, and made copy.deepcopy fail on non-leaf, grad-tracking or vmap-batched tensors. Submodule dicts and empty tensor dicts are still compared by identity; non-empty tensor dicts are compared by length and which values are None, so removals, additions and None assignments are caught and swaps are not. __deepcopy__ skips the record, _validate records it once, and the docs list what is not detected. The parity benchmark now takes the fastest of ten interleaved rounds per side and keeps 2.0x for the arithmetic-bound convolution case. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
martyn
force-pushed
the
fix/runtime-gaps
branch
from
September 26, 2026 20:29
1bf5050 to
b3f74b8
Compare
Contributor
Author
|
Review findings, addressed in b3f74b8 (squashed as 0ac014f): Fixed
Declined
🤖 Generated with Claude Code |
Merged
martyn
added a commit
that referenced
this pull request
Sep 26, 2026
* Add equalized learning rate to linear and transformer projections * Add HNDL primitives for style transformer coordinate rendering * Bump README status to 0.6.0 and drop host-application references The README status line was missed in the 0.6.0 release; a test now ties it to hndl.__version__. HNDL is a base library, so release notes, SPEC, and test docstrings no longer name a particular downstream consumer. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Keep 0.6.0 saved plans loading when operators gain arguments (#81) Adding equalized= to linear, attention and feed_forward without a version bump made every 0.6.0 plan holding those operators fail to load with E_INTEGRITY and changed their semantic digests. Arg gains since="<release>" for arguments added to a released operator. A resolved node that holds such an argument's default omits it from its args and argument origins; construct() fills it back in. Plans that do not use the new argument keep their 0.6.0 bytes and digests, and 0.6.0 plans load. equalized is declared since="0.7.0". Adds plan fixtures generated by the 0.6.0 release and a regression test that loads, builds and re-resolves them, and documents the rule in docs/ADDING_OPERATORS.md. Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Relax strictness that costs more than it protects (#82) * Parse configs in process instead of in a subprocess worker The AST allowlist is unchanged and source is still never compiled or executed. hndl/_parser.py replaces the python -I -S worker, its JSON wire protocol, response validation and resource limits. Before ast.parse, a token-stream screen bounds bracket nesting (50) and Python operators or keywords (32; valid configs use none): on CPython 3.11-3.13 a few thousand chained operators otherwise crash ast.parse with SIGSEGV on a small thread stack. Parser MemoryError/RecursionError become E_RESOURCE. Statement handling is one dispatch table on each side: Validator.STATEMENTS in _parser.py and _Interpreter.STATEMENTS in config.py. The concat timing test now counts solver shape updates instead of racing a 5 s subprocess timeout. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Explain plan mismatches and fill values a saved plan determines Revalidation lists every differing port shape and argument per node instead of a one-line E_INTEGRITY. A plan missing only an operator default or an argument bound to a verified port dimension loads completed, with a warning naming the filled values and the new semantic digest. Missing values only a policy or relation search would choose are still refused. Digest mismatches say the file is corrupted or was hand-edited. Raise the default max_state_bytes from 1 GiB to 64 GiB (a 405M-parameter network failed to build by default), drop from_json's 16 MiB cap and its duplicate max_nodes check, and have capture read max_nodes from the shared limits. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Document in-process parsing, plan completion and limit defaults Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Make the attention deepcopy test perturb bias entries independently Adding a constant to the whole relative-position bias table shifts every logit equally, which softmax cancels, so the assertion passed or failed on rounding noise (flaky on CI 3.14). Independent normal perturbations change the output for every input tried (0 of 500 indistinguishable). Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Validate each input signature once instead of every port on every call (#83) * Validate each input signature once instead of every port on every call GraphModule._execute() checked the shape, dtype and device of every port of every node, and replayed the registered-state walk, on every forward call: a fixed ~10 us per node that made a five-node MLP at batch 32 run ~1.7x hand-written PyTorch. The first call for a given input signature (every external input's shape, dtype and device, plus training mode and autocast state) now runs the full checked program and the state check, as before. The signature is then remembered, and later calls with it compare the signature and run the modules back to back from a slot-indexed program. What was validated is invalidated on the events that can break it: - .to()/.cuda()/.double()/... (_apply) drops every signature and forces a full state re-check; - registering a parameter, buffer or submodule on any module in the graph (register_* or attribute assignment) advances a watch generation through torch's global registration hooks, filtered to modules of built graphs, so the next call re-checks state and revalidates every port; a registration during a fast call is checked at the end of that call, as before. Errors are readable: port mismatches name the node, operation and source line and show the contract in HNDL notation ("[B=32, 64]:float32 on cpu") beside the tensor that arrived; torch errors raised inside a node are wrapped as E_RUNTIME with the node's inputs and any state change that explains them; OOM errors pass through unwrapped. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Document validation once per input signature CHANGELOG, README, IMPLEMENTATION and SPEC describe when contracts are checked, what invalidates a validated signature, the new error wording, and the registered-state edits PyTorch runs no hook for. The parity benchmark's docstring now describes the cheap path it actually times. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Keep exceptions raised inside a node as their own type, with a note Wrapping a torch error raised inside a node in HNDLError (a ValueError) broke callers that catch RuntimeError around a forward call. The original exception now propagates unchanged --- type, message and traceback --- and gains one add_note() naming the node, its operation and source line, its inputs against their contract, any registered-state change that explains the failure, the upstream port that drifted after validation, and a hint when the error came from torch.compile. An exception passing out through nested graphs keeps only the innermost node's note. HNDLError (E_RUNTIME) is kept for what HNDL's own checks find: first-call validation and state mismatches. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Add bounded for loops to the config grammar (#84) `for _ in range(N):` with a positive int literal N repeats its body, which may hold any top-level statement including nested loops. The interpreter unrolls it before resolution, so a loop yields the same node IDs, plan, semantic digest and state_dict keys as the statements written out by hand. Explicit names gain the per-level iteration suffix (block3, res1_3), node source metadata records the iterations, and configuration, resolution and runtime errors report them. The multiplied-out node count is checked against max_nodes before the first node is emitted, loops nest at most 8 levels, and every other loop, conditional and comprehension form is rejected by name. The ViT and GPT example networks now use loops for their blocks. Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Close extension API gaps for operators defined outside HNDL (#86) * Close extension API gaps for operators defined outside HNDL - The global `ops` namespace resolves aliases against the registry of the active capture, so custom operators work as `ops.my_op()` under resolve_callable/network_from_callable(registry=...). A registry.ops factory whose exact declaration the capture's registry lacks now fails with E_CAPTURE and a message naming the registry to pass. - `hndl.relations` publishes the convolution arithmetic, spatial, elementwise_join and broadcast relations, plus conv_input_range, conv_transpose_input, conv_axis and conv_transpose_axis. Built-ins import from it; operators._relations re-exports it. - `hndl.testing` publishes the operator harness (check_operator and the per-check functions, example_params/operator_params for pytest). The built-in test_all_operators runs through it. pytest is imported lazily. - Tests in tests/test_extension_api.py exercise all three as an external package would. SPEC, README, ADDING_OPERATORS and CHANGELOG updated. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Test the harness's failure paths and address review nits - Exercise every check_build_and_run, check_declaration, check_round_trip and check_reference failure with a deliberately broken operator (or, for checks that guard HNDL itself, a patched resolver/repr/replay), asserting each message, so a check that stops checking fails the suite. - check_reference no longer crashes when a reference drops the gradient the module carries; it reports it. - check_declaration requires the class's own docstring instead of accepting one inherited from nn.Module. - check_operator accepts devices="cpu" / dtypes="float32". - A declaration missing from the registry fails with AssertionError, like one registered with a different declaration. - The E_CAPTURE hint only suggests ops.<alias> when that alias binds the same identity in the capture's registry. - conv_axis / conv_transpose_axis fail with E_CONSTRAINT for a port whose rank lacks the axis instead of leaking IndexError. - The README's my_silu declares an Example so check_operator runs on it, with a test that executes the README block through the harness. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Detect cleared parameters on the fast path and tighten the parity tolerance (#87) * Detect registered-state edits PyTorch runs no hook for on the fast path `del module.weight`, `linear.bias = None` and direct writes to a module's `_parameters`, `_buffers` or `_modules` fire none of torch's global registration hooks, so after the first validated call the unchecked path kept running (a layer silently without its bias) until a new signature, a move or cast, or a failing layer forced a full check. Each graph now records every module's three stores together with a copy of each whenever its state is found to match the build, and every call compares the two tuples in one C-level comparison: values are compared by identity first, so an unchanged store costs about 10-17 ns and never touches its tensors. A mismatch takes the validating path, which reports removed or added state with the usual E_RUNTIME naming the node and the change, and re-checks every port when a tensor was swapped in under the same name. .to()/casts drop the recorded copies so replaced tensors are released immediately. torch.compile tracing is unchanged: the compiling path returns before the comparison. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Tighten the parity benchmark tolerance from 2.0x to 1.5x Sixteen runs of the opt-in benchmark suite with the registered-state comparison in place measured mlp 1.00-1.13x, conv_stack 0.97-1.17x and transformer_block 1.10-1.24x of hand-written PyTorch. 1.5x leaves about 20% over the worst of those. The docstring records the runs, the machine, and the one noisy conv_stack reading (1.91x, on the code before this branch) that a loaded machine can produce. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Compare registered state without holding or comparing tensors The per-call store check compared copies of every _parameters/_buffers dict with ==, so a tensor swapped in under its name (functional_call) ran an elementwise Tensor.__eq__ and a full re-check on every call, kept the swapped tensors and their autograd graphs alive, and made copy.deepcopy fail on non-leaf, grad-tracking or vmap-batched tensors. Submodule dicts and empty tensor dicts are still compared by identity; non-empty tensor dicts are compared by length and which values are None, so removals, additions and None assignments are caught and swaps are not. __deepcopy__ skips the record, _validate records it once, and the docs list what is not detected. The parity benchmark now takes the fastest of ten interleaved rounds per side and keeps 2.0x for the arithmetic-bound convolution case. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * Release 0.8.0 Bump version, README status, and rename the Unreleased changelog heading for the extension API (registry-aware ops, public hndl.relations, hndl.testing) and fast-path detection of hookless state edits. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Two follow-ups to #83 (contracts checked once per input signature).
1. Hookless registered-state edits are caught on the next call
After the first validated call,
del module.weight,linear.bias = None, and direct writes to_parameters/_buffers/_moduleswent unnoticed on the fast path, because PyTorch's global registration hooks don't fire for them. A layer could run without its bias until a new signature, a.to(), or a failing layer forced a full check.Design (
src/hndl/torch.py)GraphModule._record_stores()builds a record whenever the registered state has just been found to match the build. That happens at construction, in__deepcopy__for the clone's own modules, and once at the end of each_validate._executecompares the record with the live dictionaries on every call, in C:_parameters/_buffersare compared assame == copies, a tuple of dict copies, with identity first. This catches a submodule added, removed, set toNoneor replaced, and any entry added to an empty dict. The copies hold only submodules and empty dicts._parameters/_buffersare compared by shape: each dict's length, then whether each value isNone(map(operator.is_, chain(views), repeat(None))). This catches an entry removed, added or set toNonewithout holding or comparing any tensor.A mismatch goes down the existing
_validatepath, the same way a registration-hook bump does, and raises the usualE_RUNTIMEnaming the node and the change, for exampleregistered state of linear 'hidden' no longer matches the build: parameter 'nodes.n_hidden.bias' was set to None.A tensor swapped in under a registered name is not a change. It stays on the unchecked path, like an in-place update. So
torch.func.functional_call(grad, vmap, ensembles, hypernetworks) costs what it cost on develop, no swapped-in tensor is kept alive, andcopy.deepcopyafter a functional call works for non-leaf, grad-tracking and vmap-batched tensors.__deepcopy__skips the record and rebuilds it.Not detected, and documented in SPEC §11, IMPLEMENTATION.md, the
GraphModuledocstring and the CHANGELOG:module._parameters = {...});_parameters/_buffersbetween two calls;__eq__says it equals the old one.torch.compile: the compiling branch returns before the comparison, so this is unchanged.
Cost
The check alone, measured in isolation:
transformer_block(4)This costs more than the first version's single
stores == copies(~0.2 / 0.5 us). That version compared tensors with==, which is what madefunctional_call160x slower with a large first parameter. No C-level comparison of a tensor against a record avoids both holding the tensor and callingTensor.__eq__on a swap, so the tensor dicts pay for themap/chainiteration instead.functional_call, alternating two parameter dicts, loaded machine: develop / this PRembedding(50000, 512)first: 84 / 87 usThese are within noise. The first version of this PR measured 34,000 us for the embedding case.
2. Parity tolerance 2.0x -> 1.5x
_comparenow times each side in 10 interleaved rounds, alternating which side goes first, and compares the fastest round's median on each side, instead of one sequential mean each. Twelve runs at load average 3-7:With 20 extra busy-looping processes (load average 6-17), the MLP measured 0.95-1.06x and the transformer 1.16-1.38x. A single-thread trial put the transformer at 1.49x. The conv case is almost all arithmetic, and its ratio swings from process to process whatever the timing method, so it keeps 2.0x as a gross-regression check. The test docstring records all of this, including the 1.51x (MLP) and 2.12x (conv) that sequential timing gave under load.
Checks
PYTHONPATH=src python -m pytest -q -m "not network and not benchmark": 3702 passed, 80 skippedruff check src tests examples: cleanPYTHONPATH=src python -m hndl.docs --check: current🤖 Generated with Claude Code