mianbin/ops-pro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

事务修改

Browse Source
This commit is contained in:
even 2025-06-10 09:50:08 +08:00
parent d083c2be99
commit 898de4e49a
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/manager/impl/DefaultRunContextManager.java
View File

@ -152,7 +152,8 @@ public class DefaultRunContextManager implements RunContextManager {
} }
pipelineRunContext.changeContextStateAndChild(stateEnum); pipelineRunContext.changeContextStateAndChild(stateEnum);
} }
@Transactional(rollbackFor = Exception.class) // 记录日志需要新事物，成功或失败不影响流水线执行
@Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRES_NEW)
public void toHistory(String pipelineId){ public void toHistory(String pipelineId){
log.info("========================开始入库"); log.info("========================开始入库");
BaseRunContext context = getContext(pipelineId); BaseRunContext context = getContext(pipelineId);

2
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/manager/impl/MemoryLogManager.java
View File

@ -118,7 +118,7 @@ public class MemoryLogManager implements LoggerManager {
} }
} }
} }
@Transactional @Transactional(rollbackFor = Exception.class)
public void flushMemory(List<TaskRunContext> taskContextList){ public void flushMemory(List<TaskRunContext> taskContextList){
log.info("流水线日志开始入库"); log.info("流水线日志开始入库");
List<PipTaskLog> insertList = new ArrayList<>(); List<PipTaskLog> insertList = new ArrayList<>();