Jacob Magar 5a3e8e285b fix(subscriptions): bound snapshot loops with asyncio.timeout, raise on collect errors ...

- Wrap async-for loops in asyncio.timeout() so both subscribe_once and subscribe_collect
  cannot hang indefinitely when no messages arrive after the handshake
- subscribe_once: TimeoutError → ToolError("Subscription timed out after Xs")
- subscribe_collect: TimeoutError → pass (return events collected so far)
- Remove manual deadline checks inside the loops (now redundant)
- subscribe_collect now raises ToolError on GraphQL payload errors instead of silently dropping them
- subscribe_collect handshake now distinguishes connection_error (auth) from unexpected type

2026-03-15 18:52:27 -04:00

..

__init__.py

lintfree

2025-08-12 11:35:00 -04:00

diagnostics.py

fix: address PR review threads (test-actions, diagnostics, docker, health, storage, plugin)

2026-03-13 23:19:50 -04:00

manager.py

fix: address PR review critical and high findings

2026-03-13 15:23:12 -04:00

resources.py

merge: subscription fixes from worktree (validation, byte cap, autostart, URL scheme)

2026-03-13 10:48:05 -04:00

snapshot.py

fix(subscriptions): bound snapshot loops with asyncio.timeout, raise on collect errors

2026-03-15 18:52:27 -04:00

utils.py

merge: subscription fixes from worktree (validation, byte cap, autostart, URL scheme)

2026-03-13 10:48:05 -04:00