diff --git a/waku/v2/protocol/filter/waku_filter.go b/waku/v2/protocol/filter/waku_filter.go
index 53b0705c..fd1ca234 100644
--- a/waku/v2/protocol/filter/waku_filter.go
+++ b/waku/v2/protocol/filter/waku_filter.go
@@ -152,6 +152,8 @@ func (wf *WakuFilter) pushMessage(subscriber Subscriber, msg *pb.WakuMessage) er
 	// We connect first so dns4 addresses are resolved (NewStream does not do it)
 	err := wf.h.Connect(wf.ctx, wf.h.Peerstore().PeerInfo(subscriber.peer))
 	if err != nil {
+		wf.subscribers.FlagAsFailure(subscriber.peer)
+		wf.log.Error("failed to connect to peer", err)
 		return err
 	}