|
@@ -92,6 +92,10 @@ public class TaskService {
|
|
log.info("TaskService--state 接收到参数为:taskId=" + taskId + ",state=" + state + ",podName=" + podName);
|
|
log.info("TaskService--state 接收到参数为:taskId=" + taskId + ",state=" + state + ",podName=" + podName);
|
|
|
|
|
|
TaskPO taskPO = taskMapper.selectById(taskId);
|
|
TaskPO taskPO = taskMapper.selectById(taskId);
|
|
|
|
+ if (taskPO == null) {
|
|
|
|
+ log.error("TaskService--state 接收到已删除但还在执行的任务:taskId=" + taskId + ",state=" + state + ",podName=" + podName);
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
String projectId = taskPO.getPId();
|
|
String projectId = taskPO.getPId();
|
|
String userId = taskPO.getCreateUserId();
|
|
String userId = taskPO.getCreateUserId();
|
|
SshClient client = SshUtil.getClient();
|
|
SshClient client = SshUtil.getClient();
|