From 479b125e09b58e6fb27f2aa031d8d58d85320e16 Mon Sep 17 00:00:00 2001 From: Kasra Hajian Date: Tue, 13 Feb 2024 23:32:39 +0330 Subject: [PATCH] Fix datanode message count metric (#45) --- datanode/src/datanode_server.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/datanode/src/datanode_server.py b/datanode/src/datanode_server.py index d7dce37..dc47dba 100644 --- 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)