From ab924c0e6b707eb490083159e56d443629b1ef3e Mon Sep 17 00:00:00 2001
From: even <827656971@qq.com>
Date: Mon, 19 May 2025 15:22:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=89=A7=E8=A1=8C=E5=99=A8=E7=9B=B8=E5=85=B3?=
 =?UTF-8?q?=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ci/process/engine/dispatcher/impl/SerialDispatcher.java      | 1 +
 .../ci/process/engine/executor/impl/DefaultPipelineExecutor.java | 1 +
 .../main/java/cd/casic/ci/process/engine/worker/BaseWorker.java  | 1 +
 3 files changed, 3 insertions(+)

diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/dispatcher/impl/SerialDispatcher.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/dispatcher/impl/SerialDispatcher.java
index 3f302f62..e600efc3 100644
--- a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/dispatcher/impl/SerialDispatcher.java
+++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/dispatcher/impl/SerialDispatcher.java
@@ -53,6 +53,7 @@ public class SerialDispatcher implements BaseDispatcher {
                     && state.get() != ContextStateEnum.BAD_ENDING.getCode()) {
                 Thread.sleep(1000L);
             }
+            //
         }
     }
 
diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/executor/impl/DefaultPipelineExecutor.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/executor/impl/DefaultPipelineExecutor.java
index 703a43c1..0d8e0e32 100644
--- a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/executor/impl/DefaultPipelineExecutor.java
+++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/executor/impl/DefaultPipelineExecutor.java
@@ -52,6 +52,7 @@ public class DefaultPipelineExecutor implements PipelineExecutor {
         if (CollectionUtils.isEmpty(mainStage)) {
             throw new ServiceException(GlobalErrorCodeConstants.PIPELINE_ERROR.getCode(),"未找到有效阶段信息");
         }
+        // 如果要做 容灾就需要重新将数据库存的记录按顺序加载入
         PipelineRunContext pipelineRunContext = new PipelineRunContext(null,pipeline,new ConcurrentHashMap<>(),new ConcurrentHashMap<>());
         ParallelDispatcher parallelDispatcher = new ParallelDispatcher(mainStage,pipelineRunContext,runContextManager,redisMQTemplate,serialExecutor);
         parallelExecutor.execute(parallelDispatcher);
diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/BaseWorker.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/BaseWorker.java
index c03b3aba..d31d7928 100644
--- a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/BaseWorker.java
+++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/BaseWorker.java
@@ -36,6 +36,7 @@ public abstract class BaseWorker implements Runnable{
         BaseRunContext context = contextManager.getContext(contextKey);
         if (context instanceof TaskRunContext taskRunContext){
             try {
+                taskRunContext.changeContextState(ContextStateEnum.RUNNING);
                 execute(taskRunContext);
             } catch (Exception e) {
                 taskRunContext.changeContextState(ContextStateEnum.BAD_ENDING);