cleaning up

Signed-off-by: Elena Kolevska <[email protected]>

Author: elena-kolevska

metrics.py

@@ -323,12 +323,6 @@ def update_calculated_metrics(self):
             return
 
         with self._lock:
-            base_labels = {
-                'app_name': self.app_name,
-                'service_name': self.service_name,
-                'instance_id': self.instance_id
-            }
-
             # Calculate overall throughput and error rate
             total_ops = sum(m.total_count for m in self._metrics.values())
             total_errors = sum(m.error_count for m in self._metrics.values())

test_runner.py

@@ -111,16 +111,16 @@ def _worker_thread(self, pool: RedisClientPool, thread_id: int):
                     ops_executed = workload.execute_operation()
                     end_op_time = time.time()
 
-                    # Record metrics for each operation executed
-                    if ops_executed > 0:
-                        operation_duration = (end_op_time - start_op_time) / ops_executed
-                        for _ in range(ops_executed):
-                            self.metrics.record_operation("BATCH", operation_duration, True)
-                        operation_count += ops_executed
-                    else:
-                        # Record failed operation
-                        operation_duration = end_op_time - start_op_time
-                        self.metrics.record_operation("BATCH", operation_duration, False, "Operation failed")
+                    # # Record metrics for each operation executed
+                    # if ops_executed > 0:
+                    #     operation_duration = (end_op_time - start_op_time) / ops_executed
+                    #     for _ in range(ops_executed):
+                    #         self.metrics.record_operation("BATCH", operation_duration, True)
+                    #     operation_count += ops_executed
+                    # else:
+                    #     # Record failed operation
+                    #     operation_duration = end_op_time - start_op_time
+                    #     self.metrics.record_operation("BATCH", operation_duration, False, "Operation failed")
 
                     # Rate limiting
                     if thread_target_ops: