refactor: simplify running non-async callback using asyncio.to_thread

This commit is contained in:
lores 2025-03-31 23:22:59 +03:00
parent 7e8dcc6852
commit 47c6141f8c

View file

@ -41,11 +41,7 @@ class CallableObject:
wrapped = partial(self.callback, *args, **self._prepare_kwargs(kwargs))
if self.awaitable:
return await wrapped()
loop = asyncio.get_event_loop()
context = contextvars.copy_context()
wrapped = partial(context.run, wrapped)
return await loop.run_in_executor(None, wrapped)
return await asyncio.to_thread(wrapped)
@dataclass