Browse Source

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

Romain 6 years ago
parent
commit
fbea472423
1 changed files with 3 additions and 0 deletions
  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]