refactor(highlighting): Fix inferencer import issue (#5)

Author: haodeqi

_version.py

@@ -1,4 +1,4 @@
 # Semantic versioning
 # MAJOR.MINOR.PATCH
 
-__version__ = '0.6.3'
+__version__ = '0.6.4'

assistant_dialog_skill_analysis/__init__.py

@@ -1 +1 @@
-__version__ = '0.6.3'
+__version__ = '0.6.4'

assistant_dialog_skill_analysis/inferencing/inferencer.py

@@ -24,7 +24,7 @@ def inference(conversation, workspace_id, test_data, max_retries=10, max_thread=
             attempt = 1
             while attempt <= max_retries:
                 try:
-                    prediction_json = retrieve_classifier_response(
+                    prediction_json = skills_util.retrieve_classifier_response(
                         conversation, workspace_id, test_example, True)
                     time.sleep(.3)
 
@@ -118,25 +118,6 @@ def thread_inference(conversation, workspace_id, test_data,
     result_df = pd.DataFrame(data=result)
     return result_df
 
-def retrieve_classifier_response(conversation, workspace_id, text_input, alternate_intents=False):
-    """
-    retrieve classifier response
-    :param conversation: instance
-    :param workspace_id: workspace or skill id
-    :param text_input: the input utterance
-    :param alternate_intents:
-    :return response:
-    """
-    response = conversation.message(
-        input={
-            'message_type': 'text',
-            'text': text_input
-        },
-        workspace_id=workspace_id,
-        alternate_intents=alternate_intents,
-    ).get_result()
-    return response
-
 def get_intents_confidences(conversation, workspace_id, text_input):
     """
     Retrieve a list of confidence for analysis purpose
@@ -145,7 +126,7 @@ def get_intents_confidences(conversation, workspace_id, text_input):
     :param text_input: input utterance
     :return intent_conf: intent confidences
     """
-    response_info = retrieve_classifier_response(
+    response_info = skills_util.retrieve_classifier_response(
         conversation, workspace_id, text_input, True)['intents']
     intent_conf = [(r['intent'], r['confidence']) for r in response_info]
     return intent_conf

assistant_dialog_skill_analysis/inferencing/multi_thread_inference.py

@@ -3,15 +3,14 @@
 import _thread
 
 from ..utils import skills_util
-from ..inferencing import inferencer
 
 class InferenceThread(threading.Thread):
     """
     InferenceThread class is used for multi-thread inferencing for faster inference speed
     """
     def __init__(self, thread_id, name, que, conversation,
                  workspace_id, result, max_retries=10, verbose=False):
-        '''
+        """
         Initialize inferencer
         :param thread_id:
         :param name:
@@ -21,7 +20,7 @@ def __init__(self, thread_id, name, que, conversation,
         :param result:
         :param max_retries:
         :param verbose:
-        '''
+        """
         threading.Thread.__init__(self)
         self.thread_id = thread_id
         self.name = name
@@ -34,17 +33,17 @@ def __init__(self, thread_id, name, que, conversation,
         self.exitflag = 0
 
     def run(self):
-        '''
+        """
         Start thread
-        '''
+        """
         print("Starting " + self.name)
         self.thread_inference()
         print("Exiting " + self.name)
 
     def thread_inference(self):
-        '''
+        """
         Define thread run logic
-        '''
+        """
         while not self.exitflag:
             if not self.que.empty():
                 attempt = 1
@@ -58,7 +57,7 @@ def thread_inference(self):
                         break
                     attempt += 1
                     try:
-                        response = inferencer.retrieve_classifier_response(
+                        response = skills_util.retrieve_classifier_response(
                             self.conversation,
                             self.workspace_id,
                             query_question,
@@ -100,7 +99,7 @@ def thread_inference(self):
                 self.exit()
 
     def exit(self):
-        '''
+        """
         Exit thread
-        '''
+        """
         self.exitflag = 1

assistant_dialog_skill_analysis/utils/skills_util.py

@@ -289,3 +289,23 @@ def _remove_experimentation(nb):
             new_nb_cells.append(cell)
     nb.cells = new_nb_cells
     return nb
+
+
+def retrieve_classifier_response(conversation, workspace_id, text_input, alternate_intents=False):
+    """
+    retrieve classifier response
+    :param conversation: instance
+    :param workspace_id: workspace or skill id
+    :param text_input: the input utterance
+    :param alternate_intents:
+    :return response:
+    """
+    response = conversation.message(
+        input={
+            'message_type': 'text',
+            'text': text_input
+        },
+        workspace_id=workspace_id,
+        alternate_intents=alternate_intents,
+    ).get_result()
+    return response