Update.

Browse Source
This commit is contained in:
retoor 2025-01-27 03:48:53 +01:00
parent 374db23669
commit f3d12a257e
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/snek/service/socket.py
View File

@ -27,6 +27,8 @@ class SocketService(BaseService):
await ws.send_json(message) await ws.send_json(message)
except Exception as ex: except Exception as ex:
print(ex) print(ex)
print("Deleting socket.")
self.subscriptions[channel_uid].remove(ws)
continue continue
count += 1 count += 1
return count return count

2
src/snek/system/cache.py
View File

@ -61,7 +61,7 @@ class Cache:
if is_new: if is_new:
self.version += 1 self.version += 1
print("New version:", self.version, flush=True) print("Cache store! New version:", self.version, flush=True)
async def delete(self, args): async def delete(self, args):
if args in self.cache: if args in self.cache: