55from __future__ import annotations
66
77import pathlib
8+ import platform
89import random
910import string
1011from io import BytesIO
@@ -536,13 +537,13 @@ def cb_sub(_: DBNRecord) -> None:
536537
537538 live_client .start ()
538539
540+ await live_client .wait_for_close ()
541+
539542 second_sub = mock_live_server .get_message_of_type (
540543 gateway .SubscriptionRequest ,
541544 timeout = 1 ,
542545 )
543546
544- await live_client .wait_for_close ()
545-
546547 # Assert
547548 assert first_sub .symbols == "TEST0"
548549 assert second_sub .symbols == "TEST1"
@@ -839,6 +840,7 @@ def test_live_add_stream_path_directory(
839840 live_client .add_stream (tmp_path )
840841
841842
843+ @pytest .mark .skipif (platform .system () == "Windows" , reason = "flaky on windows" )
842844async def test_live_async_iteration (
843845 live_client : client .Live ,
844846) -> None :
@@ -955,6 +957,7 @@ async def test_live_async_iteration_dropped(
955957 assert live_client ._dbn_queue .empty ()
956958
957959
960+ @pytest .mark .skipif (platform .system () == "Windows" , reason = "flaky on windows" )
958961async def test_live_async_iteration_stop (
959962 live_client : client .Live ,
960963) -> None :
@@ -981,6 +984,7 @@ async def test_live_async_iteration_stop(
981984 assert live_client ._dbn_queue .empty ()
982985
983986
987+ @pytest .mark .skipif (platform .system () == "Windows" , reason = "flaky on windows" )
984988def test_live_sync_iteration (
985989 live_client : client .Live ,
986990) -> None :
0 commit comments