dnrops
/
python-oracledb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use methods that work with older versions of Python.

This commit is contained in:
Anthony Tuininga 2023-12-19 11:47:11 -07:00
parent a4c13ab15f
commit 4e7c63f2d2
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/oracledb/impl/thin/protocol.pyx
View File

@ -745,11 +745,11 @@ cdef class BaseAsyncProtocol(BaseProtocol):
try:
coroutine = self._process_message_helper(message)
await asyncio.wait_for(coroutine, timeout_obj)
except TimeoutError:
except asyncio.TimeoutError:
try:
coroutine = self._process_timeout_helper(message, timeout)
await asyncio.wait_for(coroutine, timeout_obj)
except TimeoutError:
except asyncio.TimeoutError:
self._force_close()
errors._raise_err(errors.ERR_CONNECTION_CLOSED,
"socket timed out while recovering from " \
@ -770,9 +770,9 @@ cdef class BaseAsyncProtocol(BaseProtocol):
message.process(self._read_buf)
if self._break_in_progress:
try:
async with asyncio.timeout(timeout_obj):
await self._receive_packet(message)
except TimeoutError:
coroutine = self._receive_packet(message)
await asyncio.wait_for(coroutine, timeout_obj)
except asyncio.TimeoutError:
self._force_close()
errors._raise_err(errors.ERR_CONNECTION_CLOSED,
"socket timed out while awaiting break " \