diff --git a/src/server/server.py b/src/server/server.py
index a4cb808d7236..cecabfe13dee 100644
--- a/src/server/server.py
+++ b/src/server/server.py
@@ -162,7 +162,7 @@ async def await_closed(self):
         """
         Await until the pipeline is done, after which the server and all clients are closed.
         """
-        await self._pipeline_task
+        self._pipeline_task.cancel()
 
     def push_message(self, message: OutboundMessage):
         """