Fix.

TeskaLabs · Aug 15, 2023 · f81e7df · f81e7df
1 parent 221e9ef
commit f81e7df
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/asab/log.py b/asab/log.py
@@ -448,8 +448,7 @@ def _on_write(self):
 
 		while not self._queue.empty():
 			# TODO: Handle eventual error in writing -> break the cycle and restart on write handler
-			log_record = self._queue.get_nowait()
-			msg = log_record.getMessage().encode("utf-8")
+			msg = self._queue.get_nowait()
 			self._socket.sendall(msg)
 
 
@@ -480,7 +479,7 @@ def emit(self, record):
 					self._enqueue(msg)
 
 			else:
-				self._enqueue(record)
+				self._enqueue(msg)
 
 
 		except Exception as e: