@@ -203,38 +203,3 @@ def test_reject_cloud_event_invalid_token(self):
203
203
assert reject .succeeded_lock_tokens == []
204
204
assert type (reject .failed_lock_tokens [0 ]) == FailedLockToken
205
205
assert reject .failed_lock_tokens [0 ].lock_token == "faketoken"
206
-
207
- @pytest .mark .live_test_only
208
- def test_release_cloud_event_event_delivery_time (self ):
209
- eventgrid_endpoint = os .environ ["EVENTGRID_ENDPOINT" ]
210
- topic_name = os .environ ["TOPIC_NAME" ]
211
- event_subscription_name = os .environ ["EVENT_SUBSCRIPTION_NAME" ]
212
-
213
- client = self .create_eg_client (eventgrid_endpoint )
214
- event = CloudEvent (
215
- type = "Contoso.Items.ItemReceived" ,
216
- source = "l" ,
217
- subject = "MySubject" ,
218
- data = {"itemSku" : "Contoso Item SKU #1" },
219
- )
220
-
221
- client .publish_cloud_events (topic_name , event )
222
- time .sleep (10 )
223
-
224
- event = client .receive_cloud_events (
225
- topic_name , event_subscription_name , max_events = 1
226
- )
227
- lock_token = event .value [0 ].broker_properties .lock_token
228
- lock_tokens = ReleaseOptions (lock_tokens = [lock_token ])
229
- start = time .time ()
230
-
231
- client .release_cloud_events (
232
- topic_name , event_subscription_name , lock_tokens = lock_tokens
233
- )
234
- event_receive_again = client .release_cloud_events (
235
- topic_name , event_subscription_name , lock_tokens = lock_tokens
236
- )
237
- if time .time () - start <= 1000 :
238
- assert event_receive_again .failed_lock_tokens [0 ].lock_token == lock_token
239
- else :
240
- assert True
0 commit comments