fix: strip line number corruption from 12 media DSPY files

The ad5d8c0 commit had line number prefixes (1|, 2|, ...) baked into
file content. Also fixed cache call bugs:
- params_kw.model or 'qwen3-max' -> params_kw.model
- 'ktv_pipeline' hardcoded -> catelogid variable
- extra tab before params_kw.llmcatelogid
- missing f-string braces in debug()
This commit is contained in:
yumoqing 2026-07-27 10:22:34 +08:00
parent a4aa40faf5
commit a2937d3cff
12 changed files with 312 additions and 324 deletions

View File

@ -1,30 +1,29 @@
1|# KTV Media API - asr-transcribe
2|# /v1/media/asr-transcribe
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'asr-transcribe'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - asr-transcribe
# /v1/media/asr-transcribe
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'asr-transcribe'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - demucs-separate
2|# /v1/media/demucs-separate
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'demucs-separate'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - demucs-separate
# /v1/media/demucs-separate
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'demucs-separate'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - face-compare
2|# /v1/media/face-compare
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'face-compare'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - face-compare
# /v1/media/face-compare
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'face-compare'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - face-detect
2|# /v1/media/face-detect
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'face-detect'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - face-detect
# /v1/media/face-detect
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'face-detect'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - face-recognize
2|# /v1/media/face-recognize
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'face-recognize'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - face-recognize
# /v1/media/face-recognize
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'face-recognize'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - merge-video
2|# /v1/media/merge-video
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'merge-video'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - merge-video
# /v1/media/merge-video
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'merge-video'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - realesrgan-upscale
2|# /v1/media/realesrgan-upscale
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'realesrgan-upscale'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - realesrgan-upscale
# /v1/media/realesrgan-upscale
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'realesrgan-upscale'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - rvc-convert
2|# /v1/media/rvc-convert
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'rvc-convert'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - rvc-convert
# /v1/media/rvc-convert
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'rvc-convert'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - songrate-evaluate
2|# /v1/media/songrate-evaluate
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'songrate-evaluate'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - songrate-evaluate
# /v1/media/songrate-evaluate
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'songrate-evaluate'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - subtitle-render
2|# /v1/media/subtitle-render
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'subtitle-render'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - subtitle-render
# /v1/media/subtitle-render
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'subtitle-render'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - synth-generate
2|# /v1/media/synth-generate
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'synth-generate'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - synth-generate
# /v1/media/synth-generate
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'synth-generate'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)

View File

@ -1,30 +1,29 @@
1|# KTV Media API - video-eval-evaluate
2|# /v1/media/video-eval-evaluate
3|
4|debug_params('params_kw', params_kw)
5|
6|userid = await get_user()
7|userorgid = await get_userorgid()
8|if userid is None:
9| return openai_403()
10|
11|catelogid = 'ktv_pipeline'
12|model_name = 'video-eval-evaluate'
13|params_kw.model = model_name
14|params_kw.catelogid = catelogid
15|
16|env = request._run_ns
17|# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model or 'qwen3-max', 'ktv_pipeline')
# KTV Media API - video-eval-evaluate
# /v1/media/video-eval-evaluate
debug_params('params_kw', params_kw)
userid = await get_user()
userorgid = await get_userorgid()
if userid is None:
return openai_403()
catelogid = 'ktv_pipeline'
model_name = 'video-eval-evaluate'
params_kw.model = model_name
params_kw.catelogid = catelogid
env = request._run_ns
# llmid from cache (model+catelogid -> llmid)
llmid = await env.get_llmid_cached(env, params_kw.model, catelogid)
if not llmid:
debug(f'model not found: params_kw.model')
debug(f'model not found: {params_kw.model}')
return openai_400()
params_kw.llmid = llmid
28| params_kw.llmcatelogid = catelogid
29|
30|f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
31|if not f:
32| return openai_429()
33|
34|return await inference(request, env=env)
35|
params_kw.llmcatelogid = catelogid
f = await checkCustomerBalance(params_kw.llmid, userid, userorgid)
if not f:
return openai_429()
return await inference(request, env=env)