Skip to content

Commit 5f69377

Browse files
committed
remove
Signed-off-by: kangclzjc <kangz@nvidia.com>
1 parent b9d6eb4 commit 5f69377

File tree

1 file changed

+0
-47
lines changed

1 file changed

+0
-47
lines changed

operator/internal/schedulerbackend/kai/backend.go

Lines changed: 0 additions & 47 deletions
Original file line numberDiff line numberDiff line change
@@ -80,38 +80,6 @@ func (b *Backend) SyncPodGang(_ context.Context, _ *groveschedulerv1alpha1.PodGa
8080
// Phase 1: Skip PodGroup creation/update
8181
// Phase 2: Will convert PodGang to PodGroup and synchronize
8282
return nil
83-
84-
// Convert PodGang to PodGroup (disabled)
85-
// podGroup := b.convertPodGangToPodGroup(podGang)
86-
//
87-
// // Create or update PodGroup
88-
// existing := &unstructured.Unstructured{}
89-
// existing.SetGroupVersionKind(podGroupGVK())
90-
//
91-
// err := b.client.Get(ctx, client.ObjectKey{
92-
// Namespace: podGroup.GetNamespace(),
93-
// Name: podGroup.GetName(),
94-
// }, existing)
95-
//
96-
// if err != nil {
97-
// if client.IgnoreNotFound(err) != nil {
98-
// return fmt.Errorf("failed to get existing PodGroup: %w", err)
99-
// }
100-
//
101-
// // Create new PodGroup
102-
// if err := b.client.Create(ctx, podGroup); err != nil {
103-
// return fmt.Errorf("failed to create PodGroup: %w", err)
104-
// }
105-
// return nil
106-
// }
107-
//
108-
// // Update existing PodGroup
109-
// podGroup.SetResourceVersion(existing.GetResourceVersion())
110-
// if err := b.client.Update(ctx, podGroup); err != nil {
111-
// return fmt.Errorf("failed to update PodGroup: %w", err)
112-
// }
113-
//
114-
// return nil
11583
}
11684

11785
// OnPodGangDelete removes the PodGroup owned by this PodGang
@@ -120,21 +88,6 @@ func (b *Backend) OnPodGangDelete(_ context.Context, _ *groveschedulerv1alpha1.P
12088
// Phase 1: Skip PodGroup deletion
12189
// Phase 2: Will delete PodGroup when PodGang is deleted
12290
return nil
123-
124-
// Delete PodGroup (disabled)
125-
// podGroup := &unstructured.Unstructured{}
126-
// podGroup.SetGroupVersionKind(podGroupGVK())
127-
// podGroup.SetName(b.getPodGroupName(podGang))
128-
// podGroup.SetNamespace(podGang.Namespace)
129-
//
130-
// if err := b.client.Delete(ctx, podGroup); err != nil {
131-
// if client.IgnoreNotFound(err) == nil {
132-
// return nil // Already deleted
133-
// }
134-
// return fmt.Errorf("failed to delete PodGroup: %w", err)
135-
// }
136-
//
137-
// return nil
13891
}
13992

14093
// PreparePod adds KAI scheduler-specific configuration to the Pod

0 commit comments

Comments
 (0)