runner warning
@@ -443,6 +443,7 @@ class ThreadPoolExecutorRunner(ConnectionObserverRunner):
# observers should not raise exceptions during data parsing
# but if they do so - we fix it
with observer_lock:
+ self.logger.warning("Unhandled exception from '{} 'caught by runner.".format(connection_observer))
ex_msg = "Unexpected exception from {} caught by runner when processing data >>{}<< at {}:" \
" {} ".format(connection_observer, data, timestamp, exc)
if connection_observer.is_command():
