Revert: Keep data timeout for all shards

KaboomFox · claude · KaboomFox · commit 3cbf09d78617 · 2026-01-10T14:08:08.000-08:00
The reconnection overhead on low-activity shards is minimal and
not worth special-casing.

Co-Authored-By: Claude Opus 4.5 &lt;noreply@anthropic.com&gt;
diff --git a/src/connection.rs b/src/connection.rs
@@ -490,9 +490,8 @@ impl<H: WebSocketHandler> Connection<H> {
                         }
                     }
 
-                    // Check data timeout (skip for shards with few subscriptions - they may have low-activity tokens)
-                    // Shards with < 50 subscriptions are exempt since inactive markets may not send data
-                    if health.is_data_timeout() && state.subscription_count >= 50 {
+                    // Check data timeout
+                    if health.is_data_timeout() {
                         self.metrics.record_health_failure();
 
                         // Request hot switchover if channel available, otherwise regular reconnect

Original file line number	Diff line number	Diff line change
`@@ -490,9 +490,8 @@ impl<H: WebSocketHandler> Connection<H> {`
`490`	`490`	`}`
`491`	`491`	`}`
`492`	`492`
`493`		`- // Check data timeout (skip for shards with few subscriptions - they may have low-activity tokens)`
`494`		`- // Shards with < 50 subscriptions are exempt since inactive markets may not send data`
`495`		`- if health.is_data_timeout() && state.subscription_count >= 50 {`
	`493`	`+ // Check data timeout`
	`494`	`+ if health.is_data_timeout() {`
`496`	`495`	`self.metrics.record_health_failure();`
`497`	`496`
`498`	`497`	`// Request hot switchover if channel available, otherwise regular reconnect`