浏览代码

更新argo日志获取

Zhangvinjo 3 年之前
父节点
当前提交
b531b783ff
共有 1 个文件被更改,包括 2 次插入3 次删除
  1. 2 3
      src/main/java/io/renren/modules/sys/controller/VisiWorkflowController.java

+ 2 - 3
src/main/java/io/renren/modules/sys/controller/VisiWorkflowController.java

@@ -13,7 +13,6 @@ import io.minio.errors.*;
 import io.renren.common.utils.*;
 
 import io.renren.modules.sys.entity.VisiWorkflowEntity;
-import io.renren.common.utils.MyWebSocket;
 import io.renren.modules.sys.service.VisiWorkflowService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -1086,7 +1085,7 @@ public class VisiWorkflowController extends AbstractController {
         workflowcontent.put("wait", sbwait.toString());
         System.out.println(workflowcontent);
         String paramjson = JSONObject.toJSONString(workflowcontent);
-        MyWebSocket.sendMessage(paramjson);
+//        MyWebSocket.sendMessage(paramjson);
 //            Thread.sleep(1000*3);   // 休眠3秒
 //        }while(successworkflow.getStatus().getPhase()!="Succeeded"&&successworkflow.getStatus().getPhase()!="Error"&&successworkflow.getStatus().getPhase()!="Failed");
 //        MyWebSocket.sendMessage("日志获取结束");
@@ -1287,7 +1286,7 @@ public class VisiWorkflowController extends AbstractController {
             e.printStackTrace();
         }
         String podcontentjson = JSONObject.toJSONString(podcontent);
-        MyWebSocket.sendMessage(podcontentjson);
+//        MyWebSocket.sendMessage(podcontentjson);
 //            Thread.sleep(1000*3);   // 休眠3秒
 //        }while(podphase!="Succeeded"&&podphase!="Completed"&&podphase!="Failed");
 //        MyWebSocket.sendMessage("获取节点日志结束");