From 6c0184597d922b8c5df6e6701ff0f87f3a79577d Mon Sep 17 00:00:00 2001 From: teddy Date: Wed, 4 Mar 2026 01:00:26 +0900 Subject: [PATCH] =?UTF-8?q?=EB=A6=AC=EC=BB=A4=EB=B2=84=EB=A6=AC=20?= =?UTF-8?q?=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../training/train/service/JobRecoveryOnStartupService.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/java/com/kamco/cd/training/train/service/JobRecoveryOnStartupService.java b/src/main/java/com/kamco/cd/training/train/service/JobRecoveryOnStartupService.java index 61644d1..37084b0 100644 --- a/src/main/java/com/kamco/cd/training/train/service/JobRecoveryOnStartupService.java +++ b/src/main/java/com/kamco/cd/training/train/service/JobRecoveryOnStartupService.java @@ -43,6 +43,7 @@ public class JobRecoveryOnStartupService { private final ModelTrainJobCoreService modelTrainJobCoreService; private final ModelTrainMngCoreService modelTrainMngCoreService; + private final ModelTrainMetricsJobService modelTrainMetricsJobService; /** * Docker 컨테이너가 쓰는 response(산출물) 디렉토리의 "호스트 측" 베이스 경로. 예) /data/train/response @@ -95,6 +96,8 @@ public class JobRecoveryOnStartupService { modelTrainJobCoreService.markSuccess(job.getId(), 0); // model 상태 변경 markStepSuccessByJobType(job); + // 결과 csv 파일 정보 등록 + modelTrainMetricsJobService.findTrainValidMetricCsvFiles(); } else { // 3-3) 산출물이 부족하면 실패 처리(운영 정책에 따라 "유예"도 가능) @@ -184,6 +187,8 @@ public class JobRecoveryOnStartupService { modelTrainJobCoreService.markSuccess(job.getId(), 0); // model 상태 변경 markStepSuccessByJobType(job); + // 결과 csv 파일 정보 등록 + modelTrainMetricsJobService.findTrainValidMetricCsvFiles(); } else { // 5-2) exitCode != 0 이거나 null이면 실패로 간주 → FAILED 처리