diff --git a/mlserver/parallel/dispatcher.py b/mlserver/parallel/dispatcher.py index 2c5d52763..2024df30b 100644 --- a/mlserver/parallel/dispatcher.py +++ b/mlserver/parallel/dispatcher.py @@ -154,8 +154,6 @@ async def _wait_response(self, internal_id: str) -> ModelResponseMessage: finally: del self._async_responses[internal_id] - return await async_response - async def stop(self): self._executor.shutdown() if self._process_responses_task is not None: