From b3a8c14b33961a7f2f36c41d3a2e0ca47e78cf73 Mon Sep 17 00:00:00 2001
From: even <827656971@qq.com>
Date: Sat, 7 Jun 2025 12:19:32 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E5=BF=97=E6=B7=BB=E5=8A=A0=EF=BC=8C?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E6=B7=BB=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../casic/ci/process/engine/manager/impl/MemoryLogManager.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/manager/impl/MemoryLogManager.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/manager/impl/MemoryLogManager.java
index d6b81c91..664d3c05 100644
--- a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/manager/impl/MemoryLogManager.java
+++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/manager/impl/MemoryLogManager.java
@@ -15,6 +15,7 @@ import jakarta.annotation.Resource;
 import jakarta.servlet.http.HttpServletRequest;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
@@ -117,7 +118,9 @@ public class MemoryLogManager implements LoggerManager {
             }
         }
     }
+    @Transactional
     public void flushMemory(List<TaskRunContext> taskContextList){
+        log.info("流水线日志开始入库");
         List<PipTaskLog> insertList = new ArrayList<>();
         List<PipTaskLog> updateList = new ArrayList<>();
         for (TaskRunContext taskRunContext : taskContextList) {