Skip to content
Snippets Groups Projects
Commit 26f71c27 authored by Sören Henning's avatar Sören Henning
Browse files

Enhance logging in generic SLO checker

parent 199415d4
No related branches found
No related tags found
No related merge requests found
Pipeline #6020 passed
...@@ -57,15 +57,14 @@ def check_result(result, operator: str, threshold): ...@@ -57,15 +57,14 @@ def check_result(result, operator: str, threshold):
@app.post("/",response_model=bool) @app.post("/",response_model=bool)
async def check_slo(request: Request): async def check_slo(request: Request):
data = json.loads(await request.body()) data = json.loads(await request.body())
logger.info('Received request with metadata: %s', data['metadata'])
warmup = int(data['metadata']['warmup']) warmup = int(data['metadata']['warmup'])
query_aggregation = get_aggr_func(data['metadata']['queryAggregation']) query_aggregation = get_aggr_func(data['metadata']['queryAggregation'])
rep_aggregation = get_aggr_func(data['metadata']['repetitionAggregation']) rep_aggregation = get_aggr_func(data['metadata']['repetitionAggregation'])
operator = data['metadata']['operator'] operator = data['metadata']['operator']
threshold = int(data['metadata']['threshold']) threshold = int(data['metadata']['threshold'])
for r in data["results"]:
aggr_query(r[0]["values"], warmup, query_aggregation)
query_results = [aggr_query(r[0]["values"], warmup, query_aggregation) for r in data["results"]] query_results = [aggr_query(r[0]["values"], warmup, query_aggregation) for r in data["results"]]
result = pd.DataFrame(query_results).aggregate(rep_aggregation).at[0] result = pd.DataFrame(query_results).aggregate(rep_aggregation).at[0]
return check_result(result, operator, threshold) return check_result(result, operator, threshold)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment