sfc service and sfp formatter reverted to working state

annotators/speech_function_classifier/server.py

@@ -51,8 +51,8 @@ def handler(payload: List[Dict]):
 def answer():
     st_time = time.time()
     phrases = request.json.get("phrase", [])
-    prev_phrases = request.json.get("prev_phrase", [])
-    prev_speech_funcs = request.json.get("prev_speech_function", [])
+    prev_phrases = [request.json.get("prev_phrase", [])]
+    prev_speech_funcs = [request.json.get("prev_speech_function", [])]
     payloads = []
     for phr, prev_phr, prev_speech_func in zip(phrases, prev_phrases, prev_speech_funcs):
         payloads.append(
@@ -67,9 +67,11 @@ def answer():
 @app.route("/respond_batch", methods=["POST"])  # candidate annotator
 def annotation():
     st_time = time.time()
-    phrases = request.json.get("phrase", [])
-    prev_phrases = request.json.get("prev_phrase", [])
-    prev_speech_funcs = request.json.get("prev_speech_function", [])
+    responses, phrases, prev_phrases, prev_speech_funcs = [], [], [], []
+    for payload in request.json:
+        phrases.append(payload["phrase"])
+        prev_phrases.append(payload["prev_phrase"])
+        prev_speech_funcs.append(payload["prev_speech_function"])
     payloads = []
     for phr, prev_phr, prev_speech_func in zip(phrases, prev_phrases, prev_speech_funcs):
         payloads.append(

annotators/speech_function_predictor/server.py

@@ -64,6 +64,7 @@ def answer():
 def annotation():
     st_time = time.time()
     payload = request.json.get("funcs", [])
+    logger.info(f"PAYLOAD IN BATCH RESPOND SFP --------------------------------: {payload}")
     responses = handler(payload)
     total_time = time.time() - st_time
     logger.info(f"speech_function_predictor batch exec time: {total_time:.3f}s")

state_formatters/dp_formatters.py

@@ -1183,7 +1183,7 @@ def speech_function_predictor_formatter(dialog: Dict):
     res = None
     res = dialog["human_utterances"][-1]["annotations"].get("speech_function_classifier", [""])
     logger.info(f"formatter log sfp/sfc: {res}")
-    return [{"funcs": [res]}]
+    return [{"funcs": res}]
 
 
 def speech_function_hypotheses_predictor_formatter(dialog: Dict):