Delete the cron job on cluster deletion
This commit is contained in:
parent
40175633a5
commit
99a3712422
|
|
@ -637,6 +637,11 @@ func (c *Cluster) Delete() {
|
|||
if err := c.deletePatroniClusterObjects(); err != nil {
|
||||
c.logger.Warningf("could not remove leftover patroni objects; %v", err)
|
||||
}
|
||||
|
||||
if err := c.deleteLogicalBackupJob(); err != nil {
|
||||
c.logger.Warningf("could not remove the logical backup k8s cron job; %v", err)
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
//NeedsRepair returns true if the cluster should be included in the repair scan (based on its in-memory status).
|
||||
|
|
@ -1016,3 +1021,14 @@ func (c *Cluster) deletePatroniClusterConfigMaps() error {
|
|||
|
||||
return c.deleteClusterObject(get, deleteConfigMapFn, "configmap")
|
||||
}
|
||||
|
||||
func (c *Cluster) deleteLogicalBackupJob() error {
|
||||
|
||||
if c.logicalBackupJob == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
c.logger.Debugf("removing the logical backup job")
|
||||
|
||||
return c.KubeClient.CronJobsGetter.CronJobs(c.Namespace).Delete(c.logicalBackupJob.ObjectMeta.Name, c.deleteOptions)
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue