Skip to content

Commit ecf40fe

Browse files
committed
rebase and add utiltypes
Signed-off-by: You-Cheng Lin (Owen) <[email protected]>
1 parent 9596618 commit ecf40fe

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

ray-operator/controllers/ray/rayjob_controller.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ import (
2828
"github.com/ray-project/kuberay/ray-operator/controllers/ray/common"
2929
"github.com/ray-project/kuberay/ray-operator/controllers/ray/metrics"
3030
"github.com/ray-project/kuberay/ray-operator/controllers/ray/utils"
31+
utiltypes "github.com/ray-project/kuberay/ray-operator/controllers/ray/utils/types"
3132
"github.com/ray-project/kuberay/ray-operator/pkg/features"
3233
)
3334

@@ -274,9 +275,9 @@ func (r *RayJobReconciler) Reconcile(ctx context.Context, request ctrl.Request)
274275

275276
// Check the current status of ray jobs
276277
jobInfoFromMapInterface, exists := jobInfoMap.Load(rayJobInstance.Name)
277-
var jobInfoFromMap utils.RayJobInfo
278+
var jobInfoFromMap utiltypes.RayJobInfo
278279
if exists {
279-
jobInfoFromMap = jobInfoFromMapInterface.(utils.RayJobInfo)
280+
jobInfoFromMap = jobInfoFromMapInterface.(utiltypes.RayJobInfo)
280281
logger.Info("JobInfoFromMap exists", "JobId", rayJobInstance.Status.JobId, "JobInfo", jobInfoFromMap.JobStatus)
281282
} else {
282283
rayDashboardClient, err := r.dashboardClientFunc(rayClusterInstance, rayJobInstance.Status.DashboardURL)

0 commit comments

Comments
 (0)