fix: debugging printouts must go into unicode string since data may carry unicode
@@ -456,9 +456,9 @@ class ThreadPoolExecutorRunner(ConnectionObserverRunner):
try:
if connection_observer.done() or self._in_shutdown:
return # even not unsubscribed secure_data_received() won't pass data to done observer
- self.logger.debug(">>> Entering {}. conn-obs '{}' runner '{}' data '{}'".format(observer_lock, connection_observer, self, data))
+ self.logger.debug(u">>> Entering {}. conn-obs '{}' runner '{}' data '{}'".format(observer_lock, connection_observer, self, data))
with observer_lock:
- self.logger.debug(">>> Entered {}. conn-obs '{}' runner '{}' data '{}'".format(observer_lock, connection_observer, self, data))
+ self.logger.debug(u">>> Entered {}. conn-obs '{}' runner '{}' data '{}'".format(observer_lock, connection_observer, self, data))
connection_observer.data_received(data, timestamp)
connection_observer.life_status.last_feed_time = time.time()
