tenant_id = (await get_userorgid()) or '0'
pipeline_id = params_kw.get('pipeline_id', '')
title = params_kw.get('title', '')
owner_id = await get_user()

if not pipeline_id:
    return json.dumps({"success": False, "message": "缺少产线ID"}, ensure_ascii=False)
if not title:
    return json.dumps({"success": False, "message": "缺少任务标题"}, ensure_ascii=False)

# Collect optional params
task_params = {}
for key in ['input_audio', 'input_video', 'input_text', 'lyrics', 'mode', 'scene']:
    val = params_kw.get(key, '')
    if val:
        task_params[key] = val

try:
    result = await pipeline_submit(tenant_id, pipeline_id, owner_id, title, task_params)
    return result
except Exception as e:
    return json.dumps({"success": False, "message": str(e)}, ensure_ascii=False)