@@ -117,19 +117,23 @@ def run_scenario(self, error_code, retry, pool_status_checker):
117
117
self .coll .insert_one ({"test" : 1 })
118
118
119
119
@client_context .require_version_min (4 , 2 , - 1 )
120
+ @client_context .require_test_commands
120
121
def test_not_master_keep_connection_pool (self ):
121
122
self .run_scenario (10107 , True , self .verify_pool_not_cleared )
122
123
123
124
@client_context .require_version_min (4 , 0 , 0 )
124
125
@client_context .require_version_max (4 , 1 , 0 , - 1 )
126
+ @client_context .require_test_commands
125
127
def test_not_master_reset_connection_pool (self ):
126
128
self .run_scenario (10107 , False , self .verify_pool_cleared )
127
129
128
130
@client_context .require_version_min (4 , 0 , 0 )
131
+ @client_context .require_test_commands
129
132
def test_shutdown_in_progress (self ):
130
133
self .run_scenario (91 , False , self .verify_pool_cleared )
131
134
132
135
@client_context .require_version_min (4 , 0 , 0 )
136
+ @client_context .require_test_commands
133
137
def test_interrupted_at_shutdown (self ):
134
138
self .run_scenario (11600 , False , self .verify_pool_cleared )
135
139
0 commit comments