yumoqing/fastwhisper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2025-11-06 12:21:21 +08:00
parent d7157beb95
commit a22dbb07b0
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
app/fastwhisper.py
View File

@ -17,14 +17,19 @@ async def get_status(request, *args, **kw):
env = request._run_ns env = request._run_ns
debug(f'get_status():{env.params_kw.task_id=}') debug(f'get_status():{env.params_kw.task_id=}')
data = await env.fastwhisper.get_status(env.params_kw.task_id) data = await env.fastwhisper.get_status(env.params_kw.task_id)
if isinstance(data['result'], str): if data['status'] == 'SUCCEEDED' and isinstance(data['result'], str):
data['result'] = json.loads(data['result']) data['result'] = json.loads(data['result'])
return ret return data
async def asr(request, *args, **kw): async def asr(request, *args, **kw):
env = request._run_ns env = request._run_ns
ret = await env.fastwhisper.submit_task(env.params_kw) ret = await env.fastwhisper.submit_task(env.params_kw)
data = await env.fastwhisper.get_status(ret['task_id']) data = None
while True:
data = await env.fastwhisper.get_status(ret['task_id'])
if data['status'] in ['SUCCEEDED', 'FAILED']:
break
await asyncio.sleep(0.2)
if data['status'] == 'SUCCEEDED': if data['status'] == 'SUCCEEDED':
s = data.get('result') s = data.get('result')
if s: if s: