tenant_id = (await get_userorgid()) or '0'
task_id = params_kw.get('task_id', '')
action = params_kw.get('action', '')

if not task_id:
    return json.dumps({"success": False, "message": "缺少task_id"}, ensure_ascii=False)

if action not in ('pause', 'resume', 'cancel'):
    return json.dumps({"success": False, "message": "action必须是pause/resume/cancel"}, ensure_ascii=False)

try:
    if action == 'pause':
        result = await pipeline_pause(tenant_id, task_id)
    elif action == 'resume':
        result = await pipeline_resume(tenant_id, task_id)
    else:
        result = await pipeline_cancel(tenant_id, task_id)
    return result
except Exception as e:
    return json.dumps({"success": False, "message": str(e)}, ensure_ascii=False)