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

Add default consumergroup value

parent a3041400
No related branches found
No related tags found
No related merge requests found
Pipeline #7192 passed
......@@ -24,7 +24,7 @@ elif os.getenv('LOG_LEVEL') == 'DEBUG':
def calculate_slope_trend(results, warmup):
d = []
for result in results:
group = result['metric']['consumergroup']
group = result['metric'].get('consumergroup', "default")
for value in result['values']:
d.append({'group': group, 'timestamp': int(
value[0]), 'value': int(value[1]) if value[1] != 'NaN' else 0})
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment