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 + ); } }