From d78027bef7f29f51ef1e4e861f84fe6a06fa08f0 Mon Sep 17 00:00:00 2001 From: Andrew Papsujko Date: Thu, 4 Sep 2025 11:14:27 +0300 Subject: [PATCH] fix: changed some replication metrics type to bigint --- mamonsu/tools/bootstrap/start.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/mamonsu/tools/bootstrap/start.py b/mamonsu/tools/bootstrap/start.py index 6fbc582..0ebd8d4 100644 --- a/mamonsu/tools/bootstrap/start.py +++ b/mamonsu/tools/bootstrap/start.py @@ -166,13 +166,13 @@ def fill_query_params(queries): 'wal_lsn' if Pooler.server_version_greater('10.0') else 'xlog_location', 'waiting' if Pooler.server_version_less('9.6.0') else 'case when wait_event_type is null then false ' ' else true end as waiting', - 'coalesce((pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn))::int, 0) AS send_lag, ' - 'coalesce((pg_wal_lsn_diff(sent_lsn, flush_lsn))::int, 0) AS receive_lag, ' - 'coalesce((pg_wal_lsn_diff(sent_lsn, write_lsn))::int, 0) AS write_lag, ' - 'coalesce((pg_wal_lsn_diff(write_lsn, flush_lsn))::int, 0) AS flush_lag, ' - 'coalesce((pg_wal_lsn_diff(flush_lsn, replay_lsn))::int, 0) AS replay_lag,' if Pooler.server_version_greater('10.0') else '', + 'coalesce((pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn))::bigint, 0) AS send_lag, ' + 'coalesce((pg_wal_lsn_diff(sent_lsn, flush_lsn))::bigint, 0) AS receive_lag, ' + 'coalesce((pg_wal_lsn_diff(sent_lsn, write_lsn))::bigint, 0) AS write_lag, ' + 'coalesce((pg_wal_lsn_diff(write_lsn, flush_lsn))::bigint, 0) AS flush_lag, ' + 'coalesce((pg_wal_lsn_diff(flush_lsn, replay_lsn))::bigint, 0) AS replay_lag,' if Pooler.server_version_greater('10.0') else '', 'wal_lsn' if Pooler.server_version_greater('10.0') else 'xlog_location', - 'send_lag INTEGER, receive_lag INTEGER, write_lag INTEGER, flush_lag INTEGER, replay_lag INTEGER,' if Pooler.server_version_greater('10.0') + 'send_lag BIGINT, receive_lag BIGINT, write_lag BIGINT, flush_lag BIGINT, replay_lag BIGINT,' if Pooler.server_version_greater('10.0') else '', 'lsn' if Pooler.server_version_greater('10.0') else 'location', 'walfile' if Pooler.server_version_greater('10.0') else 'xlogfile',