From 670adce5ff59875d5dd89ef82f8e4307ff7e38ef Mon Sep 17 00:00:00 2001 From: Joshua Timmons Date: Wed, 7 Feb 2024 17:13:47 -0500 Subject: [PATCH] Handle snapshot end more gracefully --- pkg/hcp/telemetry/state.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/hcp/telemetry/state.go b/pkg/hcp/telemetry/state.go index 6985c360..bdf447ac 100644 --- 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()