From be634ab961e45d74469c51e640e7de0601cf52f6 Mon Sep 17 00:00:00 2001 From: Raffson Date: Sun, 15 Oct 2023 20:53:03 +0200 Subject: [PATCH] Revert "Update to Python3.11" This reverts commit d6ba45a42be3717370748fa56484ebef69f4bf52. --- .github/actions/setup-liberation-python/action.yaml | 2 +- game/server/eventstream/routes.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/.github/actions/setup-liberation-python/action.yaml b/.github/actions/setup-liberation-python/action.yaml index 4d2d7877..a2992461 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.11" + python-version: "3.10" cache: pip - name: Install environment diff --git a/game/server/eventstream/routes.py b/game/server/eventstream/routes.py index d9629812..e1210bfd 100644 --- a/game/server/eventstream/routes.py +++ b/game/server/eventstream/routes.py @@ -1,4 +1,4 @@ -from asyncio import wait, create_task +from asyncio import wait 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(create_task(connection.close())) + futures.append(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(create_task(connection.send_json(jsonable_encoder(events)))) + futures.append(connection.send_json(jsonable_encoder(events))) await wait(futures)