Explorar el Código

HUE-9077 [ksql] Adding commandStatus message to the result

Romain hace 6 años
padre
commit
fbea472423
Se han modificado 1 ficheros con 3 adiciones y 0 borrados
  1. 3 0
      desktop/libs/kafka/src/kafka/ksql_client.py

+ 3 - 0
desktop/libs/kafka/src/kafka/ksql_client.py

@@ -124,6 +124,9 @@ class KSqlApi(object):
           data.append(['', ''])
           data.append(['', ''])
         else:
         else:
           data.append([key, result['sourceDescription'][key]])
           data.append([key, result['sourceDescription'][key]])
+    elif result['@type'] == 'currentStatus':
+      data.append([result['commandStatus']['status']])
+      data.append([result['commandStatus']['message']])
 
 
     columns = [[col, 'STRING'] for col in columns]
     columns = [[col, 'STRING'] for col in columns]