Skip to content

Commit 41ddfd8

Browse files
committed
fix: added recovery status check (WAL plugin)
1 parent 8d008f4 commit 41ddfd8

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

mamonsu/plugins/pgsql/wal.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -53,12 +53,13 @@ def run(self, zbx):
5353
args=["wal" if Pooler.server_version_greater("10.0") else "xlog"])
5454
zbx.send(self.key_count_wall.format("[]"), int(result[0][0]))
5555

56-
if Pooler.server_version_greater("10"):
57-
result = Pooler.query(self.query_wal_lsn_diff)
58-
zbx.send(self.key_wall.format("[]"), float(result[0][0]), self.DELTA_SPEED)
59-
else:
60-
result = Pooler.query(self.query_xlog_lsn_diff)
61-
zbx.send(self.key_wall.format("[]"), float(result[0][0]), self.DELTA_SPEED)
56+
if not Pooler.in_recovery():
57+
if Pooler.server_version_greater("10"):
58+
result = Pooler.query(self.query_wal_lsn_diff)
59+
zbx.send(self.key_wall.format("[]"), float(result[0][0]), self.DELTA_SPEED)
60+
else:
61+
result = Pooler.query(self.query_xlog_lsn_diff)
62+
zbx.send(self.key_wall.format("[]"), float(result[0][0]), self.DELTA_SPEED)
6263

6364
# PG 14 pg_stat_wal metrics
6465
if Pooler.server_version_greater("14"):

0 commit comments

Comments
 (0)