Fix thinko

matrix-org · Dec 16, 2023 · 8fe77e0 · 8fe77e0
1 parent 3abb616
commit 8fe77e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
@@ -142,7 +142,7 @@ func (r *Inputer) startWorkerForRoom(roomID string) {
 		// will linger around forever.
 
 		info, err := w.r.JetStream.ConsumerInfo(streamName, consumer)
-		if err != nil {
+		if err != nil && !errors.Is(err, nats.ErrConsumerNotFound) {
 			// log and return, we will retry anyway
 			logger.WithError(err).Errorf("failed to get consumer info")
 			return