lint: fix mypy

airtai · May 11, 2024 · df5b8b0 · df5b8b0
1 parent 7aa6d44
commit df5b8b0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/faststream/redis/opentelemetry/provider.py b/faststream/redis/opentelemetry/provider.py
@@ -1,4 +1,4 @@
-from typing import TYPE_CHECKING
+from typing import TYPE_CHECKING, cast
 
 from opentelemetry.semconv.trace import SpanAttributes
 
@@ -28,7 +28,7 @@ def get_consume_attrs_from_message(
             MESSAGING_DESTINATION_PUBLISH_NAME: msg.raw_message["channel"],
         }
 
-        if msg.raw_message.get("type", "").startswith("b"):
+        if cast(str, msg.raw_message.get("type", "")).startswith("b"):
             attrs[SpanAttributes.MESSAGING_BATCH_MESSAGE_COUNT] = len(msg.decoded_body)
 
         return attrs