Bläddra i källkod

[importer] Do not hardcode Flink interpreter id

Romain Rigaux 4 år sedan
förälder
incheckning
9f6548d8aa
1 ändrade filer med 4 tillägg och 9 borttagningar
  1. 4 9
      desktop/libs/indexer/src/indexer/indexers/flink_sql.py

+ 4 - 9
desktop/libs/indexer/src/indexer/indexers/flink_sql.py

@@ -16,23 +16,16 @@
 
 import logging
 import sys
-import uuid
 
 from django.urls import reverse
 
+from desktop.api_public import _get_interpreter_from_dialect
 from notebook.models import make_notebook
-from useradmin.models import User
-
-from desktop.lib import django_mako
-from desktop.lib.exceptions_renderable import PopupException
 
 if sys.version_info[0] > 2:
-  from urllib.parse import urlparse, unquote as urllib_unquote
   from django.utils.translation import gettext as _
 else:
   from django.utils.translation import ugettext as _
-  from urllib import unquote as urllib_unquote
-  from urlparse import urlparse
 
 
 LOG = logging.getLogger(__name__)
@@ -53,7 +46,9 @@ class FlinkIndexer():
     final_table_name = table_name
 
     source_type = source['sourceType']
-    editor_type = '55'  # destination['sourceType']
+
+    interpreter = _get_interpreter_from_dialect('flink', self.user)
+    editor_type = interpreter['type']  # destination['sourceType']
 
     columns = destination['columns']