change delete logic
This commit is contained in:
parent
4cf37c4f3e
commit
e2a4876ce4
|
|
@ -1064,11 +1064,8 @@ func (c *Cluster) deletePatroniClusterConfigMaps() error {
|
||||||
|
|
||||||
func (c *Cluster) deleteLogicalBackupJob() error {
|
func (c *Cluster) deleteLogicalBackupJob() error {
|
||||||
|
|
||||||
if c.logicalBackupJob == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
c.logger.Debug("removing the logical backup job")
|
c.logger.Debug("removing the logical backup job")
|
||||||
|
|
||||||
|
c.logicalBackupJob = nil
|
||||||
return c.KubeClient.CronJobsGetter.CronJobs(c.Namespace).Delete(c.getLogicalBackupJobName(), c.deleteOptions)
|
return c.KubeClient.CronJobsGetter.CronJobs(c.Namespace).Delete(c.getLogicalBackupJobName(), c.deleteOptions)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue