Skip to content

Commit

Permalink
Merge pull request #294 from ibuildthecloud/master
Browse files Browse the repository at this point in the history
Properly delete releases that have a custom name
  • Loading branch information
ibuildthecloud authored Feb 25, 2021
2 parents 873848c + f8008e0 commit e39527f
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 4 deletions.
2 changes: 1 addition & 1 deletion modules/agent/pkg/deployer/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ func (m *Manager) Cleanup() error {
bundleDeployment, err := m.bundleDeploymentCache.Get(m.fleetNamespace, deployed.BundleID)
if apierror.IsNotFound(err) {
logrus.Infof("Deleting orphan bundle ID %s, release %s", deployed.BundleID, deployed.ReleaseName)
if err := m.deployer.Delete(deployed.BundleID, ""); err != nil {
if err := m.deployer.Delete(deployed.BundleID, deployed.ReleaseName); err != nil {
return err
}
} else if err != nil {
Expand Down
19 changes: 16 additions & 3 deletions pkg/helmdeployer/deployer.go
Original file line number Diff line number Diff line change
Expand Up @@ -428,10 +428,23 @@ func (h *helm) Resources(bundleID, resourcesID string) (*deployer.Resources, err
}

func (h *helm) Delete(bundleID, releaseName string) error {
if releaseName != "" {
return h.deleteByRelease(bundleID, releaseName)
if releaseName == "" {
deployments, err := h.ListDeployments()
if err != nil {
return err
}
for _, deployment := range deployments {
if deployment.BundleID == bundleID {
releaseName = deployment.ReleaseName
break
}
}
}
if releaseName == "" {
// Never found anything to delete
return nil
}
return h.delete(bundleID, fleet.BundleDeploymentOptions{}, false)
return h.deleteByRelease(bundleID, releaseName)
}

func (h *helm) deleteByRelease(bundleID, releaseName string) error {
Expand Down

0 comments on commit e39527f

Please sign in to comment.