tech10001
/
jianmu-ci-server
forked from jianmu-dev/jianmu-ci-server
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: cache任务执行失败后报错

This commit is contained in:
daihw 2023-03-07 16:45:10 +08:00
parent 492d29d41f
commit fd0cdbdff0
3 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
api/src/main/java/dev/jianmu/api/eventhandler/TaskInstanceEventHandler.java
View File

@ -109,8 +109,9 @@ public class TaskInstanceEventHandler {
public void handleTaskInstanceSucceedEvent(TaskInstanceSucceedEvent event) {
// 任务上下文抛出事件通知流程上下文
logger.info("get TaskInstanceSucceedEvent: {}", event);
if (event.getDefKey().equals("start") || event.getDefKey().equals("end")) {
if (event.isCache()) {
this.cacheApplication.executeSucceeded(event.getTaskInstanceId());
return;
}
this.asyncTaskInstanceInternalApplication.succeed(event.getBusinessId());
}
@ -119,11 +120,9 @@ public class TaskInstanceEventHandler {
public void handleTaskInstanceFailedEvent(TaskInstanceFailedEvent event) {
// 任务上下文抛出事件通知流程上下文
logger.info("get TaskInstanceFailedEvent: {}", event);
if (event.getDefKey().equals("start") || event.getDefKey().equals("end")) {
if (event.isCache()) {
this.cacheApplication.executeFailed(event.getTaskInstanceId());
}
if (event.getDefKey().equals("start")) {
this.workflowInstanceInternalApplication.terminateByTriggerId(event.getTriggerId());
return;
}
this.asyncTaskInstanceInternalApplication.stop(event.getTriggerId(), event.getBusinessId());
}

4
task-core/src/main/java/dev/jianmu/task/event/TaskInstanceFailedEvent.java
View File

@ -7,6 +7,10 @@ package dev.jianmu.task.event;
* @create 2021-04-06 16:08
*/
public class TaskInstanceFailedEvent extends BaseEvent {
public boolean isCache() {
return this.asyncTaskRef.equals("cache");
}
private TaskInstanceFailedEvent() {
}

4
task-core/src/main/java/dev/jianmu/task/event/TaskInstanceSucceedEvent.java
View File

@ -7,6 +7,10 @@ package dev.jianmu.task.event;
* @create 2021-04-06 16:09
*/
public class TaskInstanceSucceedEvent extends BaseEvent {
public boolean isCache() {
return this.asyncTaskRef.equals("cache");
}
private TaskInstanceSucceedEvent() {
}