@@ -203,38 +203,3 @@ def test_reject_cloud_event_invalid_token(self):
203203 assert reject .succeeded_lock_tokens == []
204204 assert type (reject .failed_lock_tokens [0 ]) == FailedLockToken
205205 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