We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 003d89c commit 8146883Copy full SHA for 8146883
uamqp/async_ops/connection_async.py
@@ -6,6 +6,7 @@
6
7
import asyncio
8
import logging
9
+import functools
10
11
import uamqp
12
from uamqp import c_uamqp
@@ -132,7 +133,7 @@ async def work_async(self):
132
133
raise
134
try:
135
await self.lock_async()
- self._conn.do_work()
136
+ await self.loop.run_in_executor(None, functools.partial(self._conn.do_work))
137
except asyncio.TimeoutError:
138
_logger.debug("Connection %r timed out while waiting for lock acquisition.", self.container_id)
139
finally:
0 commit comments