Fix datanode message count metric (#45)

kysre · Feb 13, 2024 · 479b125 · 479b125
1 parent c04c06b
commit 479b125
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/datanode/src/datanode_server.py b/datanode/src/datanode_server.py
@@ -70,7 +70,6 @@ def __init__(self, partition_count=1, home_path='datanode/server/', metrics_prov
         self.shared_partition = SharedPartitions(partition_count, home_path=home_path + '/main/')
         self.replica = SharedPartitions(partition_count, home_path=home_path + '/replica/')
 
-    @inc_message_count
     def Push(self, request, context):
         PUSH_THROUGHPUT.labels(provider=self.metrics_provider).observe(1)
         start_time = time.time()
@@ -137,7 +136,6 @@ def PurgeReplicaData(self, request, context):
                                         home_path=self.home_path + '/replica/')
         return empty_pb2.Empty()
 
-    @dec_message_count
     def AcknowledgePull(self, request, context):
         try:
             ACK_THROUGHPUT.labels(provider=self.metrics_provider).observe(1)