Handle snapshot end more gracefully

hashicorp · Feb 7, 2024 · 670adce · 670adce
1 parent 84ef4f9
commit 670adce
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/hcp/telemetry/state.go b/pkg/hcp/telemetry/state.go
@@ -149,8 +149,8 @@ func (st *stateTrackerImpl) recvStream(stream pbresource.ResourceService_WatchLi
 		} else if ev.GetDelete() != nil {
 			st.logger.Info("hcp.v2.TelemetryState resource deleted, clearing from state")
 			st.state = nil
-		} else {
-			st.logger.Error("unexpected operation type received from WatchList stream")
+		} else if ev.GetEndOfSnapshot() == nil {
+			st.logger.Error("unexpected event operation type received from WatchList stream")
 		}
 		st.stateMu.Unlock()