# 获取集群运行状态 cluster_id = params_kw.get('cluster_id', '') if not cluster_id: return {'status': 'error', 'message': 'Missing cluster_id'} result = await cluster_status(request, cluster_id) return result