diff --git a/pkg/summarycache/summarycache.go b/pkg/summarycache/summarycache.go
index 9a96a00..616332b 100644
--- a/pkg/summarycache/summarycache.go
+++ b/pkg/summarycache/summarycache.go
@@ -81,6 +81,7 @@ func (s *SummaryCache) OnInboundRelationshipChange(ctx context.Context, schema *
 		<-ctx.Done()
 		s.Lock()
 		defer s.Unlock()
+		close(cb)
 		delete(s.cbs, id)
 	}()