From 195856b8467487ae75fb2dd3180819b7c6b9dfc9 Mon Sep 17 00:00:00 2001
From: "gayoun.park" <gayoun.park@tf.dabeeo.com>
Date: Fri, 13 Feb 2026 12:46:54 +0900
Subject: [PATCH] =?UTF-8?q?flush=20=EC=B6=94=EA=B0=80=ED=95=B4=EB=B3=B4?=
 =?UTF-8?q?=EA=B8=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cd/training/postgres/core/ModelTrainJobCoreService.java     | 1 +
 .../cd/training/postgres/core/ModelTrainMngCoreService.java     | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java
index 4bbc9d4..21f98ad 100644
--- a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java
+++ b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainJobCoreService.java
@@ -45,6 +45,7 @@ public class ModelTrainJobCoreService {
     job.setQueuedDttm(queuedDttm != null ? queuedDttm : ZonedDateTime.now());
 
     modelTrainJobRepository.save(job);
+    modelTrainJobRepository.flush();
     return job.getId();
   }
 
diff --git a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java
index 9e967ac..8861649 100644
--- a/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java
+++ b/src/main/java/com/kamco/cd/training/postgres/core/ModelTrainMngCoreService.java
@@ -312,6 +312,7 @@ public class ModelTrainMngCoreService {
     master.setCurrentAttemptId(jobId);
 
     // 필요하면 시작시간도 여기서 찍어줌
+    modelMngRepository.flush();
   }
 
   /** 마지막 에러 메시지 초기화 - 재시작/새 실행 때 이전 에러 흔적 제거 */
@@ -323,6 +324,7 @@ public class ModelTrainMngCoreService {
             .orElseThrow(() -> new IllegalArgumentException("Model not found: " + modelId));
 
     master.setLastError(null);
+    modelMngRepository.flush();
   }
 
   /** 중단 처리(옵션) - cancel에서 쓰려고 하면 같이 구현 */