|
@@ -315,11 +315,15 @@ class CompleteAgentFlow:
|
|
|
# 找到对应的指标需求
|
|
# 找到对应的指标需求
|
|
|
metric_req = next((m for m in metrics_requirements if m.metric_id == metric_id), None)
|
|
metric_req = next((m for m in metrics_requirements if m.metric_id == metric_id), None)
|
|
|
if not metric_req:
|
|
if not metric_req:
|
|
|
- print(f"⚠️ 找不到指标 {metric_id} 的需求信息,跳过")
|
|
|
|
|
- # 仍然从待计算列表中移除,避免无限循环
|
|
|
|
|
- if metric_id in new_state["pending_metric_ids"]:
|
|
|
|
|
- new_state["pending_metric_ids"].remove(metric_id)
|
|
|
|
|
- continue
|
|
|
|
|
|
|
+ # 修复:找不到指标需求时,创建临时的指标需求结构,避免跳过指标
|
|
|
|
|
+ print(f"⚠️ 指标 {metric_id} 找不到需求信息,创建临时配置继续计算")
|
|
|
|
|
+ metric_req = type('MetricRequirement', (), {
|
|
|
|
|
+ 'metric_id': metric_id,
|
|
|
|
|
+ 'metric_name': metric_id.replace('metric-', '') if metric_id.startswith('metric-') else metric_id,
|
|
|
|
|
+ 'calculation_logic': f'计算 {metric_id}',
|
|
|
|
|
+ 'required_fields': ['transactions'],
|
|
|
|
|
+ 'dependencies': []
|
|
|
|
|
+ })()
|
|
|
|
|
|
|
|
print(f"🧮 计算指标: {metric_id} - {metric_req.metric_name}")
|
|
print(f"🧮 计算指标: {metric_id} - {metric_req.metric_name}")
|
|
|
|
|
|