File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change 20
20
21
21
sys .path [0 :0 ] = ["" ]
22
22
23
- from test . synchronous import IntegrationTest , client_context , unittest
23
+ from test import IntegrationTest , client_context , unittest
24
24
from test .utils import (
25
25
HeartbeatEventListener ,
26
26
ServerEventListener ,
30
30
from pymongo import monitoring
31
31
from pymongo .hello import HelloCompat
32
32
33
- _IS_SYNC = False
33
+ _IS_SYNC = True
34
34
35
35
36
36
class TestStreamingProtocol (IntegrationTest ):
@@ -79,7 +79,7 @@ def marked_unknown():
79
79
def rediscovered ():
80
80
return len (listener .matching (_discovered_node )) >= 1
81
81
82
- # Topology events are published asynchronously
82
+ # Topology events are published synchronously
83
83
wait_until (marked_unknown , "mark node unknown" )
84
84
wait_until (rediscovered , "rediscover node" )
85
85
Original file line number Diff line number Diff line change @@ -226,6 +226,7 @@ def async_only_test(f: str) -> bool:
226
226
"test_retryable_writes.py" ,
227
227
"test_retryable_writes_unified.py" ,
228
228
"test_session.py" ,
229
+ "test_streaming_protocol.py" ,
229
230
"test_transactions.py" ,
230
231
"unified_format.py" ,
231
232
]
You can’t perform that action at this time.
0 commit comments