deemanone/beanflows
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(api): lowercase default metric names to match ALLOWED_METRICS
Some checks failed
CI / test-cli (push) Successful in 12s
Details
CI / test-sqlmesh (push) Successful in 13s
Details
CI / test-web (push) Failing after 14s
Details
CI / tag (push) Has been skipped
Details

Browse Source 
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
Deeman
2026-02-28 09:55:13 +01:00
parent e872ba0204
commit e85d0eab63
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
web/src/beanflows/api/routes.py
View File

@@ -136,7 +136,7 @@ async def list_commodities():
@api_key_required(scopes=["read"]) @api_key_required(scopes=["read"])
async def commodity_metrics(code: int): async def commodity_metrics(code: int):
"""Time series metrics for a commodity. Query params: metrics, start_year, end_year.""" """Time series metrics for a commodity. Query params: metrics, start_year, end_year."""
raw_metrics = request.args.getlist("metrics") or ["Production", "Exports", "Imports", "Ending_Stocks"] raw_metrics = request.args.getlist("metrics") or ["production", "exports", "imports", "ending_stocks"]
metrics = [m for m in raw_metrics if m in analytics.ALLOWED_METRICS] metrics = [m for m in raw_metrics if m in analytics.ALLOWED_METRICS]
if not metrics: if not metrics:
return jsonify({"error": f"No valid metrics. Allowed: {sorted(analytics.ALLOWED_METRICS)}"}), 400 return jsonify({"error": f"No valid metrics. Allowed: {sorted(analytics.ALLOWED_METRICS)}"}), 400
@@ -152,7 +152,7 @@ async def commodity_metrics(code: int):
@api_key_required(scopes=["read"]) @api_key_required(scopes=["read"])
async def commodity_countries(code: int): async def commodity_countries(code: int):
"""Country ranking for a commodity. Query params: metric, limit.""" """Country ranking for a commodity. Query params: metric, limit."""
metric = request.args.get("metric", "Production") metric = request.args.get("metric", "production")
if metric not in analytics.ALLOWED_METRICS: if metric not in analytics.ALLOWED_METRICS:
return jsonify({"error": f"Invalid metric. Allowed: {sorted(analytics.ALLOWED_METRICS)}"}), 400 return jsonify({"error": f"Invalid metric. Allowed: {sorted(analytics.ALLOWED_METRICS)}"}), 400
@@ -368,7 +368,7 @@ async def commodity_metrics_csv(code: int):
return jsonify({"error": "CSV export requires a Starter or Pro plan"}), 403 return jsonify({"error": "CSV export requires a Starter or Pro plan"}), 403
raw_metrics = request.args.getlist("metrics") or [ raw_metrics = request.args.getlist("metrics") or [
"Production", "Exports", "Imports", "Ending_Stocks", "Total_Distribution", "production", "exports", "imports", "ending_stocks", "total_distribution",
] ]
metrics = [m for m in raw_metrics if m in analytics.ALLOWED_METRICS] metrics = [m for m in raw_metrics if m in analytics.ALLOWED_METRICS]
if not metrics: if not metrics: