all: Suppress NotFound non-retryable stream errors

TheThingsNetwork · Jul 29, 2024 · 1e9c11f · 1e9c11f
1 parent b98ea9c
commit 1e9c11f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/events/mux/mux.go b/pkg/events/mux/mux.go
@@ -226,6 +226,9 @@ func (*multiplexerStore) swallowNonRetryableStreamErr(ctx context.Context, isPri
 		errors.IsResourceExhausted(err):
 		logger.Info("Stream failed with retryable error")
 		return err
+	case errors.IsNotFound(err):
+		logger.WithError(err).Debug("Stream failed with non-retryable error")
+		return nil
 	default:
 		// Other error codes are considered not retryable. They are not propagated to the caller, because that would
 		// cause the multiplexed subscription to fail.