File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
eventhub/azure-eventhub/azure/eventhub/_pyamqp/aio
servicebus/azure-servicebus/azure/servicebus/_pyamqp/aio Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -149,7 +149,7 @@ async def update_pending_deliveries(self):
149149 pending = []
150150 for delivery in self ._pending_deliveries :
151151 if delivery .timeout and (now - delivery .start ) >= delivery .timeout :
152- delivery .on_settled (LinkDeliverySettleReason .TIMEOUT , None )
152+ await delivery .on_settled (LinkDeliverySettleReason .TIMEOUT , None )
153153 continue
154154 if not delivery .sent :
155155 sent_and_settled = await self ._outgoing_transfer (delivery )
Original file line number Diff line number Diff line change @@ -149,7 +149,7 @@ async def update_pending_deliveries(self):
149149 pending = []
150150 for delivery in self ._pending_deliveries :
151151 if delivery .timeout and (now - delivery .start ) >= delivery .timeout :
152- delivery .on_settled (LinkDeliverySettleReason .TIMEOUT , None )
152+ await delivery .on_settled (LinkDeliverySettleReason .TIMEOUT , None )
153153 continue
154154 if not delivery .sent :
155155 sent_and_settled = await self ._outgoing_transfer (delivery )
You can’t perform that action at this time.
0 commit comments