diff --git a/src/snek/service/socket.py b/src/snek/service/socket.py index 55909ce..b7f172a 100644 --- a/src/snek/service/socket.py +++ b/src/snek/service/socket.py @@ -27,6 +27,8 @@ class SocketService(BaseService): await ws.send_json(message) except Exception as ex: print(ex) + print("Deleting socket.") + self.subscriptions[channel_uid].remove(ws) continue count += 1 return count diff --git a/src/snek/system/cache.py b/src/snek/system/cache.py index 86f5557..39e6fc3 100644 --- a/src/snek/system/cache.py +++ b/src/snek/system/cache.py @@ -61,7 +61,7 @@ class Cache: if is_new: self.version += 1 - print("New version:", self.version, flush=True) + print("Cache store! New version:", self.version, flush=True) async def delete(self, args): if args in self.cache: