diff --git a/tests/components/wyoming/test_satellite.py b/tests/components/wyoming/test_satellite.py index b6564afcfe9..81f5cd52e7a 100644 --- a/tests/components/wyoming/test_satellite.py +++ b/tests/components/wyoming/test_satellite.py @@ -603,18 +603,25 @@ async def test_satellite_error_during_pipeline(hass: HomeAssistant) -> None: ).event(), ] # no audio chunks after RunPipeline + client_created_event = asyncio.Event() + mock_client = SatelliteAsyncTcpClient(events) + + def _async_make_tcp_client(*args: Any, **kwargs: Any) -> SatelliteAsyncTcpClient: + client_created_event.set() + return mock_client + with patch( "homeassistant.components.wyoming.data.load_wyoming_info", return_value=SATELLITE_INFO, ), patch( "homeassistant.components.wyoming.satellite.AsyncTcpClient", - SatelliteAsyncTcpClient(events), - ) as mock_client, patch( + _async_make_tcp_client, + ), patch( "homeassistant.components.wyoming.satellite.assist_pipeline.async_pipeline_from_audio_stream", ) as mock_run_pipeline: await setup_config_entry(hass) - async with asyncio.timeout(1): + await client_created_event.wait() await mock_client.connect_event.wait() await mock_client.run_satellite_event.wait() @@ -652,13 +659,20 @@ async def test_tts_not_wav(hass: HomeAssistant) -> None: RunPipeline(start_stage=PipelineStage.TTS, end_stage=PipelineStage.TTS).event(), ] + client_created_event = asyncio.Event() + mock_client = SatelliteAsyncTcpClient(events) + + def _async_make_tcp_client(*args: Any, **kwargs: Any) -> SatelliteAsyncTcpClient: + client_created_event.set() + return mock_client + with patch( "homeassistant.components.wyoming.data.load_wyoming_info", return_value=SATELLITE_INFO, ), patch( "homeassistant.components.wyoming.satellite.AsyncTcpClient", - SatelliteAsyncTcpClient(events), - ) as mock_client, patch( + _async_make_tcp_client, + ), patch( "homeassistant.components.wyoming.satellite.assist_pipeline.async_pipeline_from_audio_stream", ) as mock_run_pipeline, patch( "homeassistant.components.wyoming.satellite.tts.async_get_media_source_audio", @@ -669,6 +683,7 @@ async def test_tts_not_wav(hass: HomeAssistant) -> None: ): entry = await setup_config_entry(hass) async with asyncio.timeout(1): + await client_created_event.wait() await mock_client.connect_event.wait() await mock_client.run_satellite_event.wait()