Skip to content

Commit 20e7875

Browse files
committed
add GetRayClusters method needed by ray_test in operator's odh test
1 parent d2e75aa commit 20e7875

File tree

2 files changed

+38
-0
lines changed

2 files changed

+38
-0
lines changed

support/ray.go

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,25 @@ func GetRayCluster(t Test, namespace, name string) *rayv1.RayCluster {
6565
return RayCluster(t, namespace, name)(t)
6666
}
6767

68+
func RayClusters(t Test, namespace string) func(g gomega.Gomega) []*rayv1.RayCluster {
69+
return func(g gomega.Gomega) []*rayv1.RayCluster {
70+
rcs, err := t.Client().Ray().RayV1().RayClusters(namespace).List(t.Ctx(), metav1.ListOptions{})
71+
g.Expect(err).NotTo(gomega.HaveOccurred())
72+
73+
rcsp := []*rayv1.RayCluster{}
74+
for _, v := range rcs.Items {
75+
rcsp = append(rcsp, &v)
76+
}
77+
78+
return rcsp
79+
}
80+
}
81+
82+
func GetRayClusters(t Test, namespace string) []*rayv1.RayCluster {
83+
t.T().Helper()
84+
return RayClusters(t, namespace)(t)
85+
}
86+
6887
func RayClusterState(cluster *rayv1.RayCluster) rayv1.ClusterState {
6988
return cluster.Status.State
7089
}

support/ray_test.go

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,3 +44,22 @@ func TestGetRayCluster(t *testing.T) {
4444
test.Expect(raycluster.Name).To(gomega.Equal("my-cluster-1"))
4545
test.Expect(raycluster.Namespace).To(gomega.Equal("my-namespace"))
4646
}
47+
48+
func TestGetRayClusters(t *testing.T) {
49+
50+
test := NewTest(t)
51+
52+
RayCluster := &rayv1alpha1.RayCluster{
53+
ObjectMeta: metav1.ObjectMeta{
54+
Name: "my-cluster-1",
55+
Namespace: "my-namespace",
56+
},
57+
}
58+
59+
test.client.Ray().RayV1().RayClusters("my-namespace").Create(test.ctx, RayCluster, metav1.CreateOptions{})
60+
rayclusters := GetRayClusters(test, "my-namespace")
61+
62+
test.Expect(len(rayclusters)).To(gomega.Equal(1))
63+
test.Expect(rayclusters[0].Name).To(gomega.Equal("my-cluster-1"))
64+
test.Expect(rayclusters[0].Namespace).To(gomega.Equal("my-namespace"))
65+
}

0 commit comments

Comments
 (0)