@@ -207,23 +207,26 @@ def test_tracked_retry_wraps_components(self):
207207 arg = 1 ,
208208 )
209209
210- @pytest .mark .parametrize ("fn_name,type_verifier" , [
211- ("retry_target" , callable ),
212- ("retry_target_stream" , inspect .isgenerator ),
213- ("retry_target_async" , inspect .iscoroutine ),
214- ("retry_target_stream_async" , inspect .isasyncgen ),
215- ])
210+ @pytest .mark .parametrize (
211+ "fn_name,type_verifier" ,
212+ [
213+ ("retry_target" , callable ),
214+ ("retry_target_stream" , inspect .isgenerator ),
215+ ("retry_target_async" , inspect .iscoroutine ),
216+ ("retry_target_stream_async" , inspect .isasyncgen ),
217+ ],
218+ )
216219 def test_wrapping_api_core (self , fn_name , type_verifier ):
217220 """Test building tracked retry from different supported retry functions"""
218221 from google .cloud .bigtable .data ._metrics import ActiveOperationMetric
222+
219223 operation = ActiveOperationMetric ("type" )
220224 fn = getattr (retry_module , fn_name )
221225 tracked_retry = self ._call_fut (
222226 retry_fn = fn ,
223227 operation = operation ,
224228 target = mock .Mock (),
225229 timeout = None ,
226- predicate = lambda x : False
230+ predicate = lambda x : False ,
227231 )
228232 assert type_verifier (tracked_retry )
229-
0 commit comments