@@ -189,6 +189,26 @@ func (c *Cluster) Sync(newSpec *cpov1.Postgresql) error {
189189 }
190190 }()
191191
192+ // Label-check for pg-pods
193+ pgLabelsChanged := ! reflect .DeepEqual (oldSpec .Spec .Labels , newSpec .Spec .Labels ) ||
194+ ! reflect .DeepEqual (oldSpec .Spec .PostgresqlParam .Labels , newSpec .Spec .PostgresqlParam .Labels )
195+
196+ // Label-check for pgbackrest-pods
197+ var oldRepoL , newRepoL map [string ]string
198+ if oldSpec .Spec .Backup != nil && oldSpec .Spec .Backup .Pgbackrest != nil {
199+ oldRepoL = oldSpec .Spec .Backup .Pgbackrest .Labels
200+ }
201+ if newSpec .Spec .Backup != nil && newSpec .Spec .Backup .Pgbackrest != nil {
202+ newRepoL = newSpec .Spec .Backup .Pgbackrest .Labels
203+ }
204+
205+ repoLabelsChanged := ! reflect .DeepEqual (oldSpec .Spec .Labels , newSpec .Spec .Labels ) ||
206+ ! reflect .DeepEqual (oldRepoL , newRepoL )
207+
208+ if pgLabelsChanged || repoLabelsChanged {
209+ c .logger .Infof ("Labels drift detected in Sync: pgLabelsChanged=%v, repoLabelsChanged=%v" , pgLabelsChanged , repoLabelsChanged )
210+ }
211+
192212 // Make sure we know about any in progress restores before touching other stuff
193213 if err = c .refreshRestoreConfigMap (); err != nil {
194214 return fmt .Errorf ("error refreshing restore configmap: %v" , err )
@@ -210,13 +230,13 @@ func (c *Cluster) Sync(newSpec *cpov1.Postgresql) error {
210230 return err
211231 }
212232
213- if err = c .syncPgbackrestConfig ( ); err != nil {
214- err = fmt .Errorf ("could not sync pgbackrest repo-host config: %v" , err )
233+ if err = c .syncPgbackrestRepoHostConfig ( & c . Spec ); err != nil {
234+ err = fmt .Errorf ("could not sync pgbackrest config: %v" , err )
215235 return err
216236 }
217237
218238 if err = c .syncPgbackrestRepoHostConfig (& c .Spec ); err != nil {
219- err = fmt .Errorf ("could not sync pgbackrest config: %v" , err )
239+ err = fmt .Errorf ("could not sync pgbackrest repo-host config: %v" , err )
220240 return err
221241 }
222242
0 commit comments