From f88cb39adc2a446f3400bcf65de1d846a25b3677 Mon Sep 17 00:00:00 2001
From: zeaslity <zeaslity@qq.com>
Date: Tue, 28 Feb 2023 17:30:19 +0800
Subject: [PATCH] =?UTF-8?q?[server][=20executor]-=20=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E9=83=A8=E5=88=86=E4=BB=A3=E7=A0=81=20-=202?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../io/wdd/agent/executor/CommandExecutor.java  | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git a/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java b/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java
index e2540a9..7992336 100644
--- a/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java
+++ b/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java
@@ -215,16 +215,9 @@ public class CommandExecutor {
                     process
             );
 
-            // 异步执行日志的发送工作
-            commandExecLogCache.CollectAndSendExecLog(
-                    streamKey,
-                    needResultReplay,
-                    octopusMessage
-            );
-
             // 执行到这里,说明整个任务流程结束(超时结束)
             log.debug(
-                    "命令 [ {} ] [ {} ]执行全流程结束! 开始释放所有资源",
+                    "命令 [ {} ] [ {} ]  执行全流程结束! 开始释放所有资源",
                     streamKey,
                     process.info()
             );
@@ -248,6 +241,14 @@ public class CommandExecutor {
                 // shutdown the process
                 process.destroyForcibly();
             }
+
+
+            // 异步执行日志的发送工作
+            commandExecLogCache.CollectAndSendExecLog(
+                    streamKey,
+                    needResultReplay,
+                    octopusMessage
+            );
         }
 
     }