(self, control_request: ControlRequest, timeout: int)
| 1756 | return responses |
| 1757 | |
| 1758 | def _call_worker(self, control_request: ControlRequest, timeout: int): |
| 1759 | request_id = control_request.request_id |
| 1760 | self.engine_worker_queue.put_tasks(([control_request], 1)) |
| 1761 | # Use a single asyncio.run() to concurrently wait for all worker responses. |
| 1762 | return asyncio.run(self._wait_for_control_responses(request_id, timeout, executors=["worker"])) |
| 1763 | |
| 1764 | def _send_error_response(self, request_id, error_msg, error_code: int = 500): |
| 1765 | self.llm_logger.error( |
no test coverage detected