瀏覽代碼

circular import error for py2

ayush.goyal 4 年之前
父節點
當前提交
c58b0a0caf
共有 2 個文件被更改,包括 5 次插入5 次删除
  1. 2 2
      desktop/libs/indexer/src/indexer/indexers/flink_sql.py
  2. 3 3
      desktop/libs/kafka/src/kafka/kafka_api.py

+ 2 - 2
desktop/libs/indexer/src/indexer/indexers/flink_sql.py

@@ -19,7 +19,7 @@ import sys
 
 from django.urls import reverse
 
-from desktop import api_public
+from desktop.api_public import *
 from notebook.models import make_notebook
 
 if sys.version_info[0] > 2:
@@ -47,7 +47,7 @@ class FlinkIndexer():
 
     source_type = source['sourceType']
 
-    interpreter = api_public._get_interpreter_from_dialect('flink', self.user)
+    interpreter = _get_interpreter_from_dialect('flink', self.user)
     editor_type = interpreter['type']  # destination['sourceType']
 
     columns = destination['columns']

+ 3 - 3
desktop/libs/kafka/src/kafka/kafka_api.py

@@ -20,7 +20,7 @@ import json
 import logging
 import sys
 
-from desktop import api_public
+from desktop.api_public import *
 from desktop.lib.django_util import JsonResponse
 from desktop.lib.i18n import force_unicode
 from metadata.manager_client import ManagerApi
@@ -112,7 +112,7 @@ def get_topics(user):
       'database': 'topics'
     }
 
-    interpreter = api_public._get_interpreter_from_dialect('ksql', user)
+    interpreter = _get_interpreter_from_dialect('ksql', user)
     api = _get_notebook_api(user, connector_id=interpreter['type'])
 
     return [
@@ -123,7 +123,7 @@ def get_topics(user):
 
 
 def get_topic_data(user, name):
-  interpreter = api_public._get_interpreter_from_dialect('ksql', user)
+  interpreter = _get_interpreter_from_dialect('ksql', user)
   api = _get_notebook_api(user, connector_id=interpreter['type'])
 
   data = api.get_sample_data(snippet={})