(self, future: Union[ResultFuture, asyncio.Future], method: str, args, kwargs)
| 240 | self.process.start() |
| 241 | |
| 242 | def _enqueue_task(self, future: Union[ResultFuture, asyncio.Future], method: str, args, kwargs): |
| 243 | task_id = uuid.uuid4() |
| 244 | self.tasks[task_id] = future |
| 245 | try: |
| 246 | self._task_queue.put((task_id, method, args, kwargs)) |
| 247 | except BaseException as e: |
| 248 | del self.tasks[task_id] |
| 249 | raise ChildProcessError("worker died") from e |
| 250 | |
| 251 | def execute_method(self, method: str, *args, **kwargs): |
| 252 | future: ResultFuture = ResultFuture() |
no outgoing calls
no test coverage detected