From 262f42d49f4c7dee464cd669cf3262c251daaf90 Mon Sep 17 00:00:00 2001 From: Hui Zhang Date: Wed, 8 Jun 2022 03:30:24 +0000 Subject: [PATCH] do not reset result for web ws api --- demos/streaming_asr_server/server.sh | 4 ++-- paddlespeech/server/engine/asr/online/asr_engine.py | 4 +++- paddlespeech/server/ws/asr_api.py | 1 + 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/demos/streaming_asr_server/server.sh b/demos/streaming_asr_server/server.sh index 0d255807..f532546e 100755 --- a/demos/streaming_asr_server/server.sh +++ b/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 & diff --git a/paddlespeech/server/engine/asr/online/asr_engine.py b/paddlespeech/server/engine/asr/online/asr_engine.py index 8fc210e5..6b9eed50 100644 --- a/paddlespeech/server/engine/asr/online/asr_engine.py +++ b/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: diff --git a/paddlespeech/server/ws/asr_api.py b/paddlespeech/server/ws/asr_api.py index ff4ec7b0..23609b41 100644 --- a/paddlespeech/server/ws/asr_api.py +++ b/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"] -- GitLab