소스 검색

[ksql] Handle without exception when ksql API returns empty

e.g. current behavior on INSERTs
Romain 5 년 전
부모
커밋
e82d4d79fe
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      desktop/libs/kafka/src/kafka/ksql_client.py

+ 2 - 2
desktop/libs/kafka/src/kafka/ksql_client.py

@@ -103,8 +103,8 @@ class KSqlApi(object):
 
   def ksql(self, statement):
     response = self.client.ksql(statement)
-    print(response)
-    return response[0]
+    LOG.debug('ksqlDB response: %s' % response)
+    return response[0] if response else {'@type': 'queries', 'queries': []}  # INSERTs return empty currently
 
 
   def query(self, statement, channel_name=None):