colin/ols
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

wiglenet: Hold a ref to the _update_neighbour_tiles bg task while it's running

Browse Source
This commit is contained in:
Teemu Ikonen
2023-06-13 15:06:18 +03:00
parent 057dd67557
commit f3709030cd
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
ols/resolver/wiglenet/wiglenet.py
View File

@@ -172,6 +172,7 @@ class WiglenetResolver(ResolverBase):
self.detail_validate = fastjsonschema.compile(wiglenet_v3_detail_valid_schema) self.detail_validate = fastjsonschema.compile(wiglenet_v3_detail_valid_schema)
self.search_lock = asyncio.Lock() self.search_lock = asyncio.Lock()
self.detail_lock = asyncio.Lock() self.detail_lock = asyncio.Lock()
self._background_tasks = set()
def can_search(self): def can_search(self):
if (self.searchq_disabled_at is not None if (self.searchq_disabled_at is not None
@@ -557,7 +558,9 @@ class WiglenetResolver(ResolverBase):
cacheres = self._cachecall(netid) cacheres = self._cachecall(netid)
if not isinstance(cacheres, bool): if not isinstance(cacheres, bool):
return cacheres return cacheres
asyncio.create_task(self._update_neighbour_tiles(nettype, tile)) task = asyncio.create_task(self._update_neighbour_tiles(nettype, tile))
self._background_tasks.add(task)
task.add_done_callback(self._background_tasks.discard)
return netd return netd