@@ -132,10 +132,10 @@ def get_summary(self) -> Dict[str, Any]:
132
132
133
133
# Operation metrics (generic for poll/consume)
134
134
operation_error_rate = (self .operation_errors / self .operation_attempts
135
- if self .operation_attempts > 0 else 0 )
136
- operation_success_rate = ((self .operation_attempts - self .operation_timeouts -
137
- self .operation_errors ) / self .operation_attempts
138
135
if self .operation_attempts > 0 else 0 )
136
+ operation_success_rate = ((self .operation_attempts - self .operation_timeouts -
137
+ self .operation_errors ) / self .operation_attempts
138
+ if self .operation_attempts > 0 else 0 )
139
139
140
140
# Operation latency analysis
141
141
if self .operation_latencies :
@@ -282,12 +282,12 @@ def validate_consumer_metrics(metrics: Dict[str, Any], bounds: ConsumerMetricsBo
282
282
messages_per_consume = metrics .get ('messages_per_consume' , 0 )
283
283
if messages_per_consume < bounds .min_messages_per_consume :
284
284
violations .append (f"Messages per consume { messages_per_consume :.2f} "
285
- f"below minimum { bounds .min_messages_per_consume } " )
285
+ f"below minimum { bounds .min_messages_per_consume } " )
286
286
287
287
empty_consume_rate = metrics .get ('empty_consume_rate' , 0 )
288
288
if empty_consume_rate > bounds .max_empty_consume_rate :
289
289
violations .append (f"Empty consume rate { empty_consume_rate :.3f} "
290
- f"exceeds maximum { bounds .max_empty_consume_rate } " )
290
+ f"exceeds maximum { bounds .max_empty_consume_rate } " )
291
291
292
292
# For poll operations, we skip batch efficiency validation since they're single-message operations
293
293
is_valid = len (violations ) == 0
0 commit comments