Skip to content

Commit 8c48e59

Browse files
committed
read all other remain data from subprocess
1 parent b5292bc commit 8c48e59

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

src/service/session.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -222,7 +222,6 @@ def start_task_with_subprocess(uid: str, cmd_file: str, request: Any):
222222
[sys.executable, os.path.join(config.cmd_path, cmd_file), "-c", temp_file_path],
223223
stdout=subprocess.PIPE, stderr=subprocess.PIPE, cwd=config.base_path,
224224
)
225-
logger.error(f"Subprocess started with pid {proc.pid}")
226225
session_manager.add_session_subprocess(uid, proc.pid)
227226
connector = MultiProcessOutputConnector()
228227
for data in connector.read_data(proc):
@@ -231,7 +230,7 @@ def start_task_with_subprocess(uid: str, cmd_file: str, request: Any):
231230
session_manager.end_session_with_ease_voice_response(uid, resp)
232231
session_manager.remove_session_subprocess(uid)
233232
else:
234-
logger.error(f"Subprocess output: {data.other}")
233+
continue
235234

236235

237236
def _check_session(uid: str, task_name: str) -> Optional[EaseVoiceResponse]:

src/utils/helper/connector.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,6 @@
44
from dataclasses import dataclass
55
from typing import Optional
66

7-
import logger
8-
97
from src.utils.response import EaseVoiceResponse
108

119

0 commit comments

Comments
 (0)