From 7444bcdf7b8b25ca2bc7fd8f435625a592d1ac46 Mon Sep 17 00:00:00 2001 From: Terrtia Date: Thu, 28 Feb 2019 16:43:48 +0100 Subject: [PATCH] fix: [worker 8] fix buffer concatenation --- server/workers/workers_8/worker.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/workers/workers_8/worker.py b/server/workers/workers_8/worker.py index 48fa12b..92bd9f6 100755 --- a/server/workers/workers_8/worker.py +++ b/server/workers/workers_8/worker.py @@ -77,6 +77,7 @@ if __name__ == "__main__": print('---- worker launched, uuid={} session_uuid={}'.format(uuid, session_uuid)) else: + ########################### # TODO: clean db on error print('Incorrect Stream, Closing worker: type={} session_uuid={}'.format(type, session_uuid)) sys.exit(1) @@ -117,7 +118,7 @@ if __name__ == "__main__": else: print('Error, infinite loop, max buffer length reached') # force new line - buffer += b'{}\n'.format(data[b'message']) + buffer += b''.join([ data[b'message'], b'\n' ]) # save data on disk