Skip to content

Detect cleared parameters on the fast path and tighten the parity tolerance - #87

Merged
martyn merged 3 commits into
developfrom
fix/runtime-gaps
Sep 26, 2026
Merged

martyn merged 3 commits into
developfrom
fix/runtime-gaps

Conversation

@martyn

@martyn martyn commented Sep 26, 2026 •

Copy link
Copy Markdown
Contributor

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/_modules went 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. _execute compares the record with the live dictionaries on every call, in C:

  • Submodule dicts and empty _parameters/_buffers are compared as same == copies, a tuple of dict copies, with identity first. This catches a submodule added, removed, set to None or replaced, and any entry added to an empty dict. The copies hold only submodules and empty dicts.
  • Non-empty _parameters/_buffers are compared by shape: each dict's length, then whether each value is None (map(operator.is_, chain(views), repeat(None))). This catches an entry removed, added or set to None without holding or comparing any tensor.

A mismatch goes down the existing _validate path, the same way a registration-hook bump does, and raises the usual E_RUNTIME naming the node and the change, for example registered 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, and copy.deepcopy after 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 GraphModule docstring and the CHANGELOG:

  • a whole dict replaced (module._parameters = {...});
  • a reorder;
  • one name removed and another added in the same _parameters/_buffers between two calls;
  • a submodule replaced by one whose __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:

graph dicts by identity dicts by shape per call
3-node test MLP 13 2 ~0.57 us
5-node benchmark MLP 18 3 ~0.7 us
transformer_block(4) 33 9 ~1.3 us

This costs more than the first version's single stores == copies (~0.2 / 0.5 us). That version compared tensors with ==, which is what made functional_call 160x slower with a large first parameter. No C-level comparison of a tensor against a record avoids both holding the tensor and calling Tensor.__eq__ on a swap, so the tensor dicts pay for the map/chain iteration instead.

functional_call, alternating two parameter dicts, loaded machine: develop / this PR

  • MLP: 77 / 102 us
  • embedding(50000, 512) first: 84 / 87 us
  • transformer block: 617 / 525 us

These are within noise. The first version of this PR measured 34,000 us for the embedding case.

2. Parity tolerance 2.0x -> 1.5x

_compare now 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:

case ratio range tolerance
mlp (batch 256) 1.02x – 1.10x 1.5x
conv_stack (batch 16) 0.60x – 1.58x 2.0x
transformer_block (batch 8) 1.06x – 1.22x 1.5x

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 skipped
  • ruff check src tests examples: clean
  • PYTHONPATH=src python -m hndl.docs --check: current

🤖 Generated with Claude Code

martyn and others added 3 commits September 26, 2026 13:49
`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
martyn merged commit 0ac014f into develop Sep 26, 2026
5 checks passed
@martyn
martyn deleted the fix/runtime-gaps branch September 26, 2026 20:31
@martyn

martyn commented Sep 26, 2026

Copy link
Copy Markdown
Contributor Author

Review findings, addressed in b3f74b8 (squashed as 0ac014f):

Fixed

  • Blocker: deepcopy after functional_call. __deepcopy__ now skips _stores and rebuilds it. The record also no longer holds any tensor. New regression test test_deepcopy_after_functional_call[plain|grad|vmap].
  • Blocker: functional_call slowdown. Non-empty _parameters/_buffers are now compared by length and which values are None, never with Tensor.__eq__. A same-name swap is no longer a change, so functional_call stays on the unchecked path. With embedding(50000, 512) first, a call alternating two parameter dicts takes 87 us, against 84 us on develop and 34 ms before this fix. _validate records the stores once per call.
  • Should-fix: retention of generated weights. The record holds no tensors. New test test_functional_call_keeps_no_generated_weights_alive.
  • Should-fix: parity tolerance headroom.
    • Each side is now timed in 10 interleaved rounds, and the ratio compares the fastest medians.
    • The MLP and transformer keep 1.5x.
    • The arithmetic-bound conv case keeps 2.0x. Its ratio swung from 0.60x to 1.58x even at load 3-7.
    • The docstring records the loaded-machine results honestly, including the 1.49x, 1.51x and 2.12x runs.
  • Should-fix: CHANGELOG conflict. Rebased on develop. Both bullets now sit under the single ## Unreleased heading.
  • Should-fix: SPEC/docs overclaim. SPEC §11, IMPLEMENTATION.md, the GraphModule docstring and the CHANGELOG now say "removing an entry, setting it to None, adding one, or replacing a submodule". They also list what is not detected: a same-name tensor swap, a whole-dict replacement, a reorder, a remove-plus-add in the same dict, and an equal-comparing submodule.
  • Nit: the functional_call test proved nothing. Replaced by test_a_tensor_swapped_in_under_its_name_stays_on_the_unchecked_path, which uses _count_checks, plus the deepcopy and retention tests.
  • Nit: inconsistent cost figures. One set of numbers is now used everywhere: ~0.7 us per call for the five-node MLP and ~1.3 us for the transformer block.

Declined

  • None. One partial: the reviewer suggested keeping swap detection with a port re-check but skipping the state check. I didn't do that, because any detection of a swap needs either an elementwise compare or a held reference. Swaps are therefore undetected, which is develop's behaviour, and this is documented.

🤖 Generated with Claude Code

@martyn martyn mentioned this pull request Sep 26, 2026
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>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant