From 16f5e67cf0629668b68d268186d7cb556434801e Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Fri, 20 Jan 2023 15:09:21 +0800
Subject: [PATCH] feat: use PowerJobRemoteEngine to replace akka

---
 .../tech/powerjob/worker/actors/TaskTrackerActor.java    | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

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