third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: use PowerJobRemoteEngine to replace akka

Browse Source
This commit is contained in:
tjq 2023-01-20 15:09:21 +08:00
parent 74358bca8d
commit 16f5e67cf0
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
powerjob-worker/src/main/java/tech/powerjob/worker/actors/TaskTrackerActor.java
View File

@ -52,10 +52,6 @@ public class TaskTrackerActor {
int taskStatus = req.getStatus(); int taskStatus = req.getStatus();
// 只有重量级任务才会有两级任务状态上报的机制 // 只有重量级任务才会有两级任务状态上报的机制
HeavyTaskTracker taskTracker = HeavyTaskTrackerManager.getTaskTracker(req.getInstanceId()); HeavyTaskTracker taskTracker = HeavyTaskTrackerManager.getTaskTracker(req.getInstanceId());
// 结束状态需要回复接受成功
if (TaskStatus.FINISHED_STATUS.contains(taskStatus)) {
return AskResponse.succeed(null);
}
// 手动停止 TaskTracker 的情况下会出现这种情况 // 手动停止 TaskTracker 的情况下会出现这种情况
if (taskTracker == null) { if (taskTracker == null) {
@ -72,6 +68,11 @@ public class TaskTrackerActor {
// 更新工作流上下文 // 更新工作流上下文
taskTracker.updateAppendedWfContext(req.getAppendedWfContext()); taskTracker.updateAppendedWfContext(req.getAppendedWfContext());
// 结束状态需要回复接受成功
if (TaskStatus.FINISHED_STATUS.contains(taskStatus)) {
return AskResponse.succeed(null);
}
return null; return null;
} }