Browse Source

修改pod状态查询

pull/87/head
西大锐 1 year ago
parent
commit
3385fbc0d9
1 changed files with 8 additions and 1 deletions
  1. +8
    -1
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/JupyterServiceImpl.java

+ 8
- 1
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/JupyterServiceImpl.java View File

@@ -101,6 +101,12 @@ public class JupyterServiceImpl implements JupyterService {

// 调用修改后的 createPod 方法,传入额外的参数
Integer podPort = k8sClientUtil.createConfiguredPod(podName, namespace, port, mountPath, pvc, image, minioPvcName, datasetPath, modelPath);
// 简单的延迟,以便 Pod 有时间启动
Thread.sleep(2500);
//查询pod状态,更新到数据库
String podStatus = k8sClientUtil.getPodStatus(podName, namespace);
devEnvironment.setStatus(podStatus);
this.devEnvironmentService.update(devEnvironment);
return masterIp + ":" + podPort;


@@ -112,7 +118,6 @@ public class JupyterServiceImpl implements JupyterService {
if (devEnvironment==null){
throw new Exception("开发环境配置不存在");
}

LoginUser loginUser = SecurityUtils.getLoginUser();
//手动构造pod名称
String podName = loginUser.getUsername().toLowerCase() +"-editor-pod" + "-" + id;
@@ -124,6 +129,8 @@ public class JupyterServiceImpl implements JupyterService {
// 使用 Kubernetes API 删除 Pod
String deleteResult = k8sClientUtil.deletePod(podName, namespace);

devEnvironment.setStatus("Terminating");
this.devEnvironmentService.update(devEnvironment);
return deleteResult + ",编辑器已停止";
}



Loading…
Cancel
Save