10000 fix: fixed Archiver plugin items source · postgrespro/mamonsu@f1c27c7 · GitHub
[go: up one dir, main page]

Skip to content

Commit f1c27c7

Browse files
authored
fix: fixed Archiver plugin items source
1 parent 33b3154 commit f1c27c7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

mamonsu/plugins/pgsql/archiver.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -161,13 +161,13 @@ def run(self, zbx):
161161
FROM pg_stat_archiver;
162162
""")[0][0])))
9453 163163
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]
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]
172172
zbx.send("{0}[{1}]".format(self.prefixes["key_prefix"], "count_files_to_archive"), queue_length)
173173
zbx.send("{0}[{1}]".format(self.prefixes["key_prefix"], "size_files_to_archive"), queue_size)

0 commit comments

Comments
 (0)
0