From 4c94fe6db3618b4d20ff5e6f728c80289b28d0f7 Mon Sep 17 00:00:00 2001 From: Kashif Khan Date: Mon, 17 Oct 2022 08:31:09 -0500 Subject: [PATCH] await async sleep --- .../tests/livetest/asynctests/test_buffered_producer_async.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdk/eventhub/azure-eventhub/tests/livetest/asynctests/test_buffered_producer_async.py b/sdk/eventhub/azure-eventhub/tests/livetest/asynctests/test_buffered_producer_async.py index b3b155f6780c..466da2abadfd 100644 --- a/sdk/eventhub/azure-eventhub/tests/livetest/asynctests/test_buffered_producer_async.py +++ b/sdk/eventhub/azure-eventhub/tests/livetest/asynctests/test_buffered_producer_async.py @@ -89,7 +89,7 @@ async def on_event(partition_context, event): consumer = EventHubConsumerClient.from_connection_string(connection_str, consumer_group="$default", uamqp_transport=uamqp_transport) receive_thread = asyncio.ensure_future(consumer.receive(on_event=on_event)) - asyncio.sleep(5) + await asyncio.sleep(5) sent_events = defaultdict(list) async def on_success(events, pid): @@ -195,7 +195,7 @@ async def on_event(partition_context, event): consumer = EventHubConsumerClient.from_connection_string(connection_str, consumer_group="$default", uamqp_transport=uamqp_transport) receive_thread = asyncio.ensure_future(consumer.receive(on_event=on_event)) - asyncio.sleep(5) + await asyncio.sleep(5) sent_events = defaultdict(list) async def on_success(events, pid):