Update.
This commit is contained in:
parent
d4a480b5ea
commit
d022cff499
@ -25,8 +25,8 @@ class BaseMapper:
|
|||||||
|
|
||||||
async def run_in_executor(self, func, *args, **kwargs):
|
async def run_in_executor(self, func, *args, **kwargs):
|
||||||
async with self.semaphore:
|
async with self.semaphore:
|
||||||
#return func(*args, **kwargs)
|
return func(*args, **kwargs)
|
||||||
return await self.loop.run_in_executor(None, lambda: 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)
|
||||||
|
Loading…
Reference in New Issue
Block a user