Merge pull request #2018 from zh794390558/ep

[server][asr] do not reset result for web ws api

demos/streaming_asr_server/server.sh

@@ -4,6 +4,6 @@ export CUDA_VISIBLE_DEVICE=0,1,2,3
 # nohup python3 punc_server.py --config_file conf/punc_application.yaml > punc.log 2>&1 &
 paddlespeech_server start --config_file conf/punc_application.yaml &> punc.log &
 
-# nohup python3 streaming_asr_server.py --config_file conf/ws_conformer_application.yaml > streaming_asr.log 2>&1 &
-paddlespeech_server start --config_file conf/ws_conformer_application.yaml &> streaming_asr.log  &
+# nohup python3 streaming_asr_server.py --config_file conf/ws_conformer_wenetspeech_application.yaml > streaming_asr.log 2>&1 &
+paddlespeech_server start --config_file conf/ws_conformer_wenetspeech_application.yaml &> streaming_asr.log  &
 

paddlespeech/server/engine/asr/online/asr_engine.py

@@ -161,7 +161,9 @@ class PaddleASRConnectionHanddler:
         self.model_reset()
         self.searcher.reset()
         self.endpointer.reset()
-        self.output_reset()
+
+        # reset hys will trancate history transcripts.
+        # self.output_reset()
 
     def reset(self):
         if "deepspeech2" in self.model_type:

paddlespeech/server/ws/asr_api.py

@@ -92,6 +92,7 @@ async def websocket_endpoint(websocket: WebSocket):
                 else:
                     resp = {"status": "ok", "message": "no valid json data"}
                     await websocket.send_json(resp)
+                    
             elif "bytes" in message:
                 # bytes for the pcm data
                 message = message["bytes"]