From cce26511d8bf260923d33f3eb019620656a761ca Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Sun, 31 Jan 2021 14:44:51 +0800
Subject: [PATCH] fix: task status rollback #190

---
 .../github/kfcfans/powerjob/common/utils/CommonUtils.java   | 6 ++++++
 .../powerjob/worker/core/executor/ProcessorRunnable.java    | 4 ++++
 2 files changed, 10 insertions(+)

diff --git a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/utils/CommonUtils.java b/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/utils/CommonUtils.java
index 78c1973a..17a5dbba 100644
--- a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/utils/CommonUtils.java
+++ b/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/utils/CommonUtils.java
@@ -155,4 +155,10 @@ public class CommonUtils {
         return StringUtils.replace(UUID.randomUUID().toString(), "-", "");
     }
 
+    public static void easySleep(long millis) {
+        try {
+            Thread.sleep(millis);
+        } catch (InterruptedException ignore) {
+        }
+    }
 }
diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java
index 8a3798cd..ef0e61ad 100644
--- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java
+++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java
@@ -2,6 +2,7 @@ package com.github.kfcfans.powerjob.worker.core.executor;
 
 import akka.actor.ActorSelection;
 import com.github.kfcfans.powerjob.common.ExecuteType;
+import com.github.kfcfans.powerjob.common.utils.CommonUtils;
 import com.github.kfcfans.powerjob.worker.OhMyWorker;
 import com.github.kfcfans.powerjob.worker.common.ThreadLocalStore;
 import com.github.kfcfans.powerjob.worker.common.constants.TaskConstant;
@@ -161,6 +162,9 @@ public class ProcessorRunnable implements Runnable {
      * @param cmd 特殊需求，比如广播执行需要创建广播任务
      */
     private void reportStatus(TaskStatus status, String result, Integer cmd) {
+
+        CommonUtils.easySleep(1);
+
         ProcessorReportTaskStatusReq req = new ProcessorReportTaskStatusReq();
 
         req.setInstanceId(task.getInstanceId());