lint fixes
authorMarcel van der Veldt <m.vanderveldt@outlook.com>
Fri, 31 Oct 2025 01:55:05 +0000 (02:55 +0100)
committerMarcel van der Veldt <m.vanderveldt@outlook.com>
Fri, 31 Oct 2025 01:55:05 +0000 (02:55 +0100)
music_assistant/helpers/buffered_generator.py
music_assistant/providers/airplay/__init__.py

index a950ae85f0c1be6240cae8114426dff89e1b80e0..6d45442ceaa99f7b714dca3bf3dff63763d99691 100644 (file)
@@ -6,12 +6,13 @@ import asyncio
 import contextlib
 from collections.abc import AsyncGenerator, Callable
 from functools import wraps
-from typing import Any, Final, ParamSpec
-
-from music_assistant_models.streamdetails import AudioFormat
+from typing import TYPE_CHECKING, Any, Final, ParamSpec, cast
 
 from music_assistant.helpers.util import close_async_generator
 
+if TYPE_CHECKING:
+    from music_assistant_models.media_items.audio_format import AudioFormat
+
 # Type variables for the buffered decorator
 _P = ParamSpec("_P")
 
@@ -23,7 +24,7 @@ DEFAULT_MIN_BUFFER_BEFORE_YIELD: Final = 5
 _ACTIVE_PRODUCER_TASKS: set[asyncio.Task[Any]] = set()
 
 
-async def buffered_audio(
+async def buffered_audio(  # noqa: PLR0915
     generator: AsyncGenerator[bytes, None],
     pcm_format: AudioFormat,
     buffer_size: int = DEFAULT_BUFFER_SIZE,
@@ -82,7 +83,7 @@ async def buffered_audio(
                         await condition.wait()
 
                     if cancelled:
-                        break
+                        break  # type: ignore[unreachable]
 
                     # Append to shared buffer
                     data_buffer.extend(chunk)
@@ -200,7 +201,7 @@ def use_audio_buffer(
         @wraps(func)
         async def wrapper(*args: _P.args, **kwargs: _P.kwargs) -> AsyncGenerator[bytes, None]:
             # Extract pcm_format from function arguments
-            pcm_format = kwargs.get(pcm_format_arg)
+            pcm_format = cast("AudioFormat | None", kwargs.get(pcm_format_arg))
             if pcm_format is None:
                 msg = f"Audio buffer decorator requires '{pcm_format_arg}' argument"
                 raise ValueError(msg)
index b6121c97597b22983f65c83d6c3b4eb034a23b3f..753700fe41195313cc13568521713ddc5aee4ec5 100644 (file)
@@ -4,7 +4,7 @@ from __future__ import annotations
 
 from typing import TYPE_CHECKING
 
-from music_assistant_models.config_entries import ProviderConfig
+from music_assistant_models.config_entries import ConfigEntry, ProviderConfig
 from music_assistant_models.enums import ConfigEntryType, ProviderFeature
 from music_assistant_models.provider import ProviderManifest
 
@@ -14,7 +14,7 @@ from music_assistant.providers.airplay.constants import CONF_ENABLE_LATE_JOIN
 from .provider import AirPlayProvider
 
 if TYPE_CHECKING:
-    from music_assistant_models.config_entries import ConfigEntry, ConfigValueType, ProviderConfig
+    from music_assistant_models.config_entries import ConfigValueType, ProviderConfig
     from music_assistant_models.provider import ProviderManifest
 
     from music_assistant.models import ProviderInstanceType