diff --git a/.github/actions/setup-liberation-python/action.yaml b/.github/actions/setup-liberation-python/action.yaml index a2992461..4d2d7877 100644 --- a/.github/actions/setup-liberation-python/action.yaml +++ b/.github/actions/setup-liberation-python/action.yaml @@ -6,7 +6,7 @@ runs: - name: Set up Python uses: actions/setup-python@v2 with: - python-version: "3.10" + python-version: "3.11" cache: pip - name: Install environment diff --git a/game/server/eventstream/routes.py b/game/server/eventstream/routes.py index e1210bfd..d9629812 100644 --- a/game/server/eventstream/routes.py +++ b/game/server/eventstream/routes.py @@ -1,4 +1,4 @@ -from asyncio import wait +from asyncio import wait, create_task from fastapi import APIRouter, WebSocket from fastapi.encoders import jsonable_encoder @@ -17,7 +17,7 @@ class ConnectionManager: async def shutdown(self) -> None: futures = [] for connection in self.active_connections: - futures.append(connection.close()) + futures.append(create_task(connection.close())) await wait(futures) async def connect(self, websocket: WebSocket) -> None: @@ -30,7 +30,7 @@ class ConnectionManager: async def broadcast(self, events: GameUpdateEventsJs) -> None: futures = [] for connection in self.active_connections: - futures.append(connection.send_json(jsonable_encoder(events))) + futures.append(create_task(connection.send_json(jsonable_encoder(events)))) await wait(futures)