fix: HandlerException ingored

faststream/prometheus/middleware.py

@@ -2,6 +2,7 @@
 from typing import TYPE_CHECKING, Any, Callable, Optional, Sequence
 
 from faststream import BaseMiddleware
+from faststream.exceptions import IgnoredException
 from faststream.prometheus.consts import (
     PROCESSING_STATUS_BY_ACK_STATUS,
     PROCESSING_STATUS_BY_HANDLER_EXCEPTION_MAP,
@@ -71,11 +72,13 @@ async def consume_scope(
 
         except Exception as e:
             err = e
-            self._metrics_manager.add_received_processed_message_exception(
-                exception_type=type(err).__name__,
-                broker=messaging_system,
-                handler=destination_name,
-            )
+
+            if not isinstance(err, IgnoredException):
+                self._metrics_manager.add_received_processed_message_exception(
+                    exception_type=type(err).__name__,
+                    broker=messaging_system,
+                    handler=destination_name,
+                )
             raise
 
         finally:

tests/prometheus/basic.py

@@ -7,7 +7,7 @@
 
 from faststream import Context
 from faststream.broker.message import AckStatus
-from faststream.exceptions import RejectMessage
+from faststream.exceptions import IgnoredException, RejectMessage
 from faststream.prometheus.middleware import (
     PROCESSING_STATUS_BY_ACK_STATUS,
     PROCESSING_STATUS_BY_HANDLER_EXCEPTION_MAP,
@@ -54,6 +54,11 @@ def settings_provider_factory(self):
             pytest.param(
                 AckStatus.rejected, None, id="rejected status without exception"
             ),
+            pytest.param(
+                AckStatus.acked,
+                IgnoredException,
+                id="acked status with ignore exception",
+            ),
         ],
     )
     async def test_metrics(
@@ -176,7 +181,7 @@ def assert_consume_metrics(
             ),
         ]
 
-        if status == ProcessingStatus.error:
+        if exception_class and not issubclass(exception_class, IgnoredException):
             assert (
                 metrics_manager.add_received_processed_message_exception.mock_calls
                 == [
@@ -187,6 +192,11 @@ def assert_consume_metrics(
                     ),
                 ]
             )
+        else:
+            assert (
+                metrics_manager.add_received_processed_message_exception.mock_calls
+                == []
+            )
 
     def assert_publish_metrics(self, metrics_manager: Any):
         settings_provider = self.settings_provider_factory(None)