From 30b78715831e6e377f58cb15bddfe9e376d76ab1 Mon Sep 17 00:00:00 2001
From: retoor <retoor@molodetz.nl>
Date: Fri, 23 May 2025 07:07:19 +0200
Subject: [PATCH] Update.
---
src/snek/view/rpc.py | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/src/snek/view/rpc.py b/src/snek/view/rpc.py
index f6192d3..7fc1658 100644
--- a/src/snek/view/rpc.py
+++ b/src/snek/view/rpc.py
@@ -360,11 +360,10 @@ class RPCView(BaseView):
async def get(self):
scheduled = []
async def schedule(uid, seconds, call):
-
scheduled.append(call)
await asyncio.sleep(seconds)
await self.services.socket.send_to_user(uid, call)
- sheduled.remove(call)
+ scheduled.remove(call)
ws = web.WebSocketResponse()
await ws.prepare(self.request)
@@ -378,8 +377,8 @@ class RPCView(BaseView):
await self.services.socket.subscribe(
ws, subscription["channel_uid"], self.request.session.get("uid")
)
- if not scheduled and self.request.app.uptime_seconds < 10:
- await schedule(self.request.session.get("uid"),1,{"event":"refresh", "data": {
+ if not scheduled and self.request.app.uptime_seconds < 5:
+ await schedule(self.request.session.get("uid"),0,{"event":"refresh", "data": {
"message": "Finishing deployment"}
}
)