Skip to content

Commit

Permalink
add condition not delete sharedVM
Browse files Browse the repository at this point in the history
  • Loading branch information
Maksym Veres authored and Maksym Veres committed Jun 17, 2024
1 parent 3221462 commit e684a44
Showing 1 changed file with 16 additions and 2 deletions.
18 changes: 16 additions & 2 deletions v3/pkg/scheduledeventserver/scheduledevent.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,8 @@ import (
"github.com/golang/glog"
"github.com/gorilla/mux"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/apimachinery/pkg/selection"
"k8s.io/client-go/util/retry"
)

Expand Down Expand Up @@ -862,8 +864,20 @@ func (s ScheduledEventServer) deleteProgressFromScheduledEvent(se *hfv1.Schedule

func (s ScheduledEventServer) deleteVMSetsFromScheduledEvent(se *hfv1.ScheduledEvent) error {
// delete all vmsets corresponding to this scheduled event
err := s.hfClientSet.HobbyfarmV1().VirtualMachineSets(util2.GetReleaseNamespace()).DeleteCollection(s.ctx, metav1.DeleteOptions{}, metav1.ListOptions{
LabelSelector: fmt.Sprintf("%s=%s", util2.ScheduledEventLabel, se.Name),
req1, err := labels.NewRequirement("shared", selection.NotEquals, []string{"true"})
if err != nil {
return err
}
req2, err := labels.NewRequirement(util2.ScheduledEventLabel, selection.Equals, []string{se.Name})
if err != nil {
return err
}
selector := labels.NewSelector()
selector = selector.Add(*req1).Add(*req2)
selectorString := selector.String()

err = s.hfClientSet.HobbyfarmV1().VirtualMachineSets(util2.GetReleaseNamespace()).DeleteCollection(s.ctx, metav1.DeleteOptions{}, metav1.ListOptions{
LabelSelector: selectorString,
})
if err != nil {
return err
Expand Down

0 comments on commit e684a44

Please sign in to comment.