remove unused func

Signed-off-by: yuteng chen <a08h0283@gmail.com>

Author: 0yukali0

flyteplugins/go/tasks/plugins/k8s/ray/ray.go

@@ -13,7 +13,6 @@ import (
 	rayv1 "github.com/ray-project/kuberay/ray-operator/apis/ray/v1"
 	"gopkg.in/yaml.v2"
 	v1 "k8s.io/api/core/v1"
-	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes/scheme"
 	"k8s.io/utils/ptr"
@@ -160,25 +159,6 @@ func buildAutoscalerOptions(options *plugins.AutoscalerOptions) *rayv1.Autoscale
 	return autoScalerOptions
 }
 
-func convertResourceEntriesToResourceList(entries []*core.Resources_ResourceEntry) v1.ResourceList {
-	resourceList := v1.ResourceList{}
-	for _, entry := range entries {
-		var name v1.ResourceName
-		switch entry.GetName() {
-		case core.Resources_CPU:
-			name = v1.ResourceCPU
-		case core.Resources_MEMORY:
-			name = v1.ResourceMemory
-		default:
-			continue
-		}
-		if q, err := resource.ParseQuantity(entry.GetValue()); err == nil {
-			resourceList[name] = q
-		}
-	}
-	return resourceList
-}
-
 func constructRayJob(taskCtx pluginsCore.TaskExecutionContext, rayJob *plugins.RayJob, objectMeta *metav1.ObjectMeta, taskPodSpec v1.PodSpec, headNodeRayStartParams map[string]string, primaryContainerIdx int, primaryContainer v1.Container) (*rayv1.RayJob, error) {
 	cfg := GetConfig()
 

flyteplugins/go/tasks/plugins/k8s/ray/ray_test.go

@@ -1593,62 +1593,6 @@ func transformStructToStructPB(t *testing.T, obj interface{}) *structpb.Struct {
 	return s
 }
 
-func TestConvertResourceEntriesToResourceList(t *testing.T) {
-	tests := []struct {
-		name     string
-		entries  []*core.Resources_ResourceEntry
-		wantKeys []corev1.ResourceName
-		wantLen  int
-	}{
-		{
-			name: "cpu entry",
-			entries: []*core.Resources_ResourceEntry{
-				{Name: core.Resources_CPU, Value: "500m"},
-			},
-			wantKeys: []corev1.ResourceName{corev1.ResourceCPU},
-			wantLen:  1,
-		},
-		{
-			name: "memory entry",
-			entries: []*core.Resources_ResourceEntry{
-				{Name: core.Resources_MEMORY, Value: "1Gi"},
-			},
-			wantKeys: []corev1.ResourceName{corev1.ResourceMemory},
-			wantLen:  1,
-		},
-		{
-			name: "unknown resource skipped",
-			entries: []*core.Resources_ResourceEntry{
-				{Name: core.Resources_ResourceName(99), Value: "1"},
-			},
-			wantLen: 0,
-		},
-		{
-			name: "invalid quantity skipped",
-			entries: []*core.Resources_ResourceEntry{
-				{Name: core.Resources_CPU, Value: "not-a-quantity"},
-			},
-			wantLen: 0,
-		},
-		{
-			name:    "empty input",
-			entries: []*core.Resources_ResourceEntry{},
-			wantLen: 0,
-		},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			result := convertResourceEntriesToResourceList(tt.entries)
-			require.NotNil(t, result)
-			assert.Len(t, result, tt.wantLen)
-			for _, key := range tt.wantKeys {
-				_, ok := result[key]
-				assert.True(t, ok, "expected key %s in result", key)
-			}
-		})
-	}
-}
-
 func TestBuildAutoscalerOptions(t *testing.T) {
 	t.Run("nil input returns nil", func(t *testing.T) {
 		assert.Nil(t, buildAutoscalerOptions(nil))