diff --git a/ray-operator/controllers/ray/batchscheduler/volcano/volcano_scheduler.go b/ray-operator/controllers/ray/batchscheduler/volcano/volcano_scheduler.go index 45d0b0d2921..a408cb6e073 100644 --- a/ray-operator/controllers/ray/batchscheduler/volcano/volcano_scheduler.go +++ b/ray-operator/controllers/ray/batchscheduler/volcano/volcano_scheduler.go @@ -3,6 +3,7 @@ package volcano import ( "context" "fmt" + "maps" "strconv" corev1 "k8s.io/api/core/v1" @@ -204,11 +205,15 @@ func createPodGroup(owner metav1.Object, podGroupName string, size int32, totalR ownerRef = *metav1.NewControllerRef(obj, rayv1.SchemeGroupVersion.WithKind("RayJob")) } + annotations := make(map[string]string, len(owner.GetAnnotations())) + maps.Copy(annotations, owner.GetAnnotations()) + podGroup := volcanoschedulingv1beta1.PodGroup{ ObjectMeta: metav1.ObjectMeta{ Namespace: owner.GetNamespace(), Name: podGroupName, OwnerReferences: []metav1.OwnerReference{ownerRef}, + Annotations: annotations, }, Spec: volcanoschedulingv1beta1.PodGroupSpec{ MinMember: size, diff --git a/ray-operator/controllers/ray/raycluster_controller.go b/ray-operator/controllers/ray/raycluster_controller.go index 131ee275fbf..2ca3f28b249 100644 --- a/ray-operator/controllers/ray/raycluster_controller.go +++ b/ray-operator/controllers/ray/raycluster_controller.go @@ -858,7 +858,7 @@ func (r *RayClusterReconciler) reconcilePods(ctx context.Context, instance *rayv } } } - logger.Info("reconcilePods", "found existing replica indices", "group", worker.GroupName, "indices", validReplicaIndices) + logger.Info("reconcilePods: found existing replica indices", "group", worker.GroupName, "indices", validReplicaIndices) } if diff > 0 { // pods need to be added