From 94abeedc96c0c9c6c34fcef93ad91e313d27b9cc Mon Sep 17 00:00:00 2001 From: Derek Wang Date: Tue, 10 Sep 2024 09:16:13 -0700 Subject: [PATCH] test case Signed-off-by: Derek Wang --- pkg/reconciler/vertex/scaling/scaling_test.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/pkg/reconciler/vertex/scaling/scaling_test.go b/pkg/reconciler/vertex/scaling/scaling_test.go index 9a2d14554b..4036e751fc 100644 --- a/pkg/reconciler/vertex/scaling/scaling_test.go +++ b/pkg/reconciler/vertex/scaling/scaling_test.go @@ -55,7 +55,8 @@ func Test_desiredReplicasSinglePartition(t *testing.T) { }, }, Status: dfv1.VertexStatus{ - Replicas: uint32(2), + Replicas: uint32(2), + ReadyReplicas: uint32(2), }, } assert.Equal(t, int32(1), s.desiredReplicas(context.TODO(), src, []float64{0}, []int64{0}, []int64{10000}, []int64{5000})) @@ -75,7 +76,8 @@ func Test_desiredReplicasSinglePartition(t *testing.T) { }, }, Status: dfv1.VertexStatus{ - Replicas: uint32(2), + Replicas: uint32(2), + ReadyReplicas: uint32(2), }, } assert.Equal(t, int32(1), s.desiredReplicas(context.TODO(), udf, []float64{0}, []int64{0}, []int64{10000}, []int64{5000})) @@ -99,7 +101,8 @@ func Test_desiredReplicasMultiplePartitions(t *testing.T) { }, }, Status: dfv1.VertexStatus{ - Replicas: uint32(2), + Replicas: uint32(2), + ReadyReplicas: uint32(2), }, }