From 0a73836fd17aa25662056f21ea4467cacb61efe3 Mon Sep 17 00:00:00 2001 From: Terrtia Date: Fri, 18 Jan 2019 17:16:04 +0100 Subject: [PATCH] fix: [server] fix --- server/server.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/server.py b/server/server.py index d476935..de326d5 100755 --- a/server/server.py +++ b/server/server.py @@ -118,7 +118,7 @@ class Echo(Protocol, TimeoutMixin): # Worker: Incorrect type if redis_server_stream.sismember('Error:IncorrectType:{}'.format(data_header['type']), self.session_uuid): self.transport.abortConnection() - redis_server_stream.delete(stream_name) + redis_server_stream.delete('stream:{}:{}'.format(data_header['type'], self.session_uuid)) redis_server_stream.srem('Error:IncorrectType:{}'.format(data_header['type']), self.session_uuid) logger.warning('Incorrect type={} detected by worker, uuid={}, session_uuid={}'.format(data_header['type'] ,data_header['uuid_header'], self.session_uuid))