Write cluster info to backup.info

EnterpriseDB · Sep 14, 2023 · 74242f4 · 74242f4
1 parent 39b3f8b
commit 74242f4
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/barman/backup.py b/barman/backup.py
@@ -604,6 +604,14 @@ def backup(self, wait=False, wait_timeout=None, name=None):
                 backup_name=name,
             )
             backup_info.set_attribute("systemid", self.server.systemid)
+            if hasattr(self.server.config, "cluster_primary"):
+                backup_info.set_attribute(
+                    "cluster_primary", self.server.config.cluster_primary
+                )
+            if hasattr(self.server.config, "cluster_backup_source"):
+                backup_info.set_attribute(
+                    "cluster_backup_source", self.server.config.cluster_backup_source
+                )
 
             backup_info.save()
             self.backup_cache_add(backup_info)

diff --git a/barman/infofile.py b/barman/infofile.py
@@ -496,10 +496,17 @@ class BackupInfo(FieldListFile):
     snapshots_info = Field(
         "snapshots_info", load=load_snapshots_info, dump=output_snapshots_info
     )
+    cluster_primary = Field("cluster_primary")
+    cluster_backup_source = Field("cluster_backup_source")
 
     __slots__ = "backup_id", "backup_version"
 
-    _hide_if_null = ("backup_name", "snapshots_info")
+    _hide_if_null = (
+        "backup_name",
+        "snapshots_info",
+        "cluster_primary",
+        "cluster_backup_source",
+    )
 
     def __init__(self, backup_id, **kwargs):
         """