Update.

Browse Source
This commit is contained in:
retoor 2025-06-01 00:38:22 +02:00
parent 161ff392d7
commit d4a480b5ea
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/snek/system/mapper.py
View File

@ -12,7 +12,7 @@ class BaseMapper:
def __init__(self, app): def __init__(self, app):
self.app = app self.app = app
self.semaphore = asyncio.Semaphore(1)
self.default_limit = self.__class__.default_limit self.default_limit = self.__class__.default_limit
@property @property
@ -24,8 +24,9 @@ class BaseMapper:
return asyncio.get_event_loop() return asyncio.get_event_loop()
async def run_in_executor(self, func, *args, **kwargs): async def run_in_executor(self, func, *args, **kwargs):
return func(*args, **kwargs) async with self.semaphore:
#return await self.loop.run_in_executor(None, lambda: func(*args, **kwargs)) #return func(*args, **kwargs)
return await self.loop.run_in_executor(None, lambda: func(*args, **kwargs))
async def new(self): async def new(self):
return self.model_class(mapper=self, app=self.app) return self.model_class(mapper=self, app=self.app)