(self, method: str, *args, **kwargs)
| 249 | raise ChildProcessError("worker died") from e |
| 250 | |
| 251 | def execute_method(self, method: str, *args, **kwargs): |
| 252 | future: ResultFuture = ResultFuture() |
| 253 | self._enqueue_task(future, method, args, kwargs) |
| 254 | return future |
| 255 | |
| 256 | async def execute_method_async(self, method: str, *args, **kwargs): |
| 257 | future = asyncio.get_running_loop().create_future() |
no test coverage detected