فهرست منبع

HUE-9187 [editor] Also send batch results via WS if available

This will simplify the POC for now.
Either the connectors is full WS or not.
Romain 5 سال پیش
والد
کامیت
11313cbc41
1فایلهای تغییر یافته به همراه9 افزوده شده و 10 حذف شده
  1. 9 10
      desktop/libs/kafka/src/kafka/ksql_client.py

+ 9 - 10
desktop/libs/kafka/src/kafka/ksql_client.py

@@ -123,7 +123,7 @@ class KSqlApi(object):
         _send_to_channel(
             channel_name,
             message_type='task.progress',
-            message_data={'status': 'running', 'query_id': 1111}
+            message_data={'status': 'running', 'query_id': 1}
         )
 
       for line in result:
@@ -144,20 +144,19 @@ class KSqlApi(object):
             data.append(data_line['row']['columns'])
         else:
           data.append([line])
-
-        if has_channels() and channel_name:
-          _send_to_channel(
-              channel_name,
-              message_type='task.result',
-              message_data={'data': data, 'metadata': metadata, 'query_id': 1111}
-          )
-          # TODO: special message when end of stream
-          data = []
     else:
       data, metadata = self._decode_result(
         self.ksql(statement)
       )
 
+    if has_channels() and channel_name:  # Send results via WS and empty results
+      _send_to_channel(
+          channel_name,
+          message_type='task.result',
+          message_data={'data': data, 'metadata': metadata, 'query_id': 1}
+      )
+      data = []  # TODO: special message when end of stream
+
     return data, metadata