@@ -161,13 +161,13 @@ def run(self, zbx):
161161 FROM pg_stat_archiver;
162162 """ )[0 ][0 ])))
163163if 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 ]
165165 .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 ]
167167 .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 ]
169169 .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 ]
171171 .format ("xlog_location" ,"xlogfile" ))[0 ][0 ]
172172zbx .send ("{0}[{1}]" .format (self .prefixes ["key_prefix" ],"count_files_to_archive" ),queue_length )
173173zbx .send ("{0}[{1}]" .format (self .prefixes ["key_prefix" ],"size_files_to_archive" ),queue_size )