@@ -166,13 +166,13 @@ def fill_query_params(queries):
166
166
'wal_lsn' if Pooler .server_version_greater ('10.0' ) else 'xlog_location' ,
167
167
'waiting' if Pooler .server_version_less ('9.6.0' ) else 'case when wait_event_type is null then false '
168
168
' else true end as waiting' ,
169
- 'coalesce((pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn))::int , 0) AS send_lag, '
170
- 'coalesce((pg_wal_lsn_diff(sent_lsn, flush_lsn))::int , 0) AS receive_lag, '
171
- 'coalesce((pg_wal_lsn_diff(sent_lsn, write_lsn))::int , 0) AS write_lag, '
172
- 'coalesce((pg_wal_lsn_diff(write_lsn, flush_lsn))::int , 0) AS flush_lag, '
173
- 'coalesce((pg_wal_lsn_diff(flush_lsn, replay_lsn))::int , 0) AS replay_lag,' if Pooler .server_version_greater ('10.0' ) else '' ,
169
+ 'coalesce((pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn))::bigint , 0) AS send_lag, '
170
+ 'coalesce((pg_wal_lsn_diff(sent_lsn, flush_lsn))::bigint , 0) AS receive_lag, '
171
+ 'coalesce((pg_wal_lsn_diff(sent_lsn, write_lsn))::bigint , 0) AS write_lag, '
172
+ 'coalesce((pg_wal_lsn_diff(write_lsn, flush_lsn))::bigint , 0) AS flush_lag, '
173
+ 'coalesce((pg_wal_lsn_diff(flush_lsn, replay_lsn))::bigint , 0) AS replay_lag,' if Pooler .server_version_greater ('10.0' ) else '' ,
174
174
'wal_lsn' if Pooler .server_version_greater ('10.0' ) else 'xlog_location' ,
175
- 'send_lag INTEGER , receive_lag INTEGER , write_lag INTEGER , flush_lag INTEGER , replay_lag INTEGER ,' if Pooler .server_version_greater ('10.0' )
175
+ 'send_lag BIGINT , receive_lag BIGINT , write_lag BIGINT , flush_lag BIGINT , replay_lag BIGINT ,' if Pooler .server_version_greater ('10.0' )
176
176
else '' ,
177
177
'lsn' if Pooler .server_version_greater ('10.0' ) else 'location' ,
178
178
'walfile' if Pooler .server_version_greater ('10.0' ) else 'xlogfile' ,
0 commit comments