File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -161,13 +161,13 @@ def run(self, zbx):
161
161
FROM pg_stat_archiver;
162
162
""" )[0 ][0 ])))
9453
163
163
if wal_exists :
164
- queue_length = Pooler .query (self .items_status ["count_files_to_archive" ]["query" ][query_type ]
164
+ queue_length = Pooler .query (self .items_queue ["count_files_to_archive" ]["query" ][query_type ]
165
165
.format ("wal_lsn" , "walfile" ) if Pooler .server_version_greater ("10.0" ) else
166
- self .items_status ["count_files_to_archive" ]["query" ][query_type ]
166
+ self .items_queue ["count_files_to_archive" ]["query" ][query_type ]
167
167
.format ("xlog_location" , "xlogfile" ))[0 ][0 ]
168
- queue_size = Pooler .query (self .items_status ["size_files_to_archive" ]["query" ][query_type ]
168
+ queue_size = Pooler .query (self .items_queue ["size_files_to_archive" ]["query" ][query_type ]
169
169
.format ("wal_lsn" , "walfile" ) if Pooler .server_version_greater ("10.0" ) else
170
- self .items_status ["size_files_to_archive" ]["query" ][query_type ]
170
+ self .items_queue ["size_files_to_archive" ]["query" ][query_type ]
171
171
.format ("xlog_location" , "xlogfile" ))[0 ][0 ]
172
172
zbx .send ("{0}[{1}]" .format (self .prefixes ["key_prefix" ], "count_files_to_archive" ), queue_length )
173
173
zbx .send ("{0}[{1}]" .format (self .prefixes ["key_prefix" ], "size_files_to_archive" ), queue_size )
You can’t perform that action at this time.
0 commit comments