hans/Nominatim
1
0
Fork 1
mirror of https://github.com/osm-search/Nominatim.git synced 2026-02-26 11:08:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

use backwards-compatible asyncio timeout implementation

Browse Source
This commit is contained in:
Sarah Hoffmann
2023-08-24 16:29:21 +02:00
parent 5a2ebfcd4a
commit 161d17d85b
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
nominatim/api/connection.py
View File

@@ -51,8 +51,7 @@ class SearchConnection:
""" Execute a 'scalar()' query on the connection.
"""
log().sql(self.connection, sql, params)
async with asyncio.timeout(self.query_timeout):
return await self.connection.scalar(sql, params)
return await asyncio.wait_for(self.connection.scalar(sql, params), self.query_timeout)
async def execute(self, sql: 'sa.Executable',
@@ -61,8 +60,7 @@ class SearchConnection:
""" Execute a 'execute()' query on the connection.
"""
log().sql(self.connection, sql, params)
async with asyncio.timeout(self.query_timeout):
return await self.connection.execute(sql, params)
return await asyncio.wait_for(self.connection.execute(sql, params), self.query_timeout)
async def get_property(self, name: str, cached: bool = True) -> str: