diff --git a/backend/telemetry_core/src/aggregator/inner_loop.rs b/backend/telemetry_core/src/aggregator/inner_loop.rs
index c24df52..0f8a1a1 100644
--- a/backend/telemetry_core/src/aggregator/inner_loop.rs
+++ b/backend/telemetry_core/src/aggregator/inner_loop.rs
@@ -439,6 +439,8 @@ impl InnerLoop {
                 }
             }
             FromShardWebsocket::Disconnected => {
+                self.shard_channels.remove(&shard_conn_id);
+
                 // Find all nodes associated with this shard connection ID:
                 let node_ids_to_remove: Vec<NodeId> = self
                     .node_ids