diff --git a/confluent_server/confluent/httpapi.py b/confluent_server/confluent/httpapi.py index d2d746fa..e1519787 100644 --- a/confluent_server/confluent/httpapi.py +++ b/confluent_server/confluent/httpapi.py @@ -422,9 +422,11 @@ def wsock_handler(ws): if isinstance(data, dict): data = json.dumps(data) ws.send(u'!' + data) - elif not isinstance(data, str): - ws.send(u' ' + data.decode('utf8')) else: + try: + data = data.decode('utf8') + except UnicodeDecodeError: + data = data.decode('cp437') ws.send(u' ' + data) try: if shellsession: