From b3b8016673d240a0bd26f57f1ba8a21ab8514a6a Mon Sep 17 00:00:00 2001 From: "gayoun.park" Date: Thu, 12 Feb 2026 21:45:38 +0900 Subject: [PATCH 1/2] =?UTF-8?q?csv=20=EA=B2=B0=EA=B3=BC=20=EB=B0=9B?= =?UTF-8?q?=EC=95=84=EC=98=A4=EB=8A=94=20=EA=B2=83=20=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/kamco/cd/training/train/service/TrainJobWorker.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java b/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java index 44dbe1d..5e17a1a 100644 --- a/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java +++ b/src/main/java/com/kamco/cd/training/train/service/TrainJobWorker.java @@ -100,10 +100,10 @@ public class TrainJobWorker { if (isEval) { modelTrainMngCoreService.markStep2Success(modelId); - modelTrainMetricsJobService.findTrainValidMetricCsvFiles(); + modelTestMetricsJobService.findTestValidMetricCsvFiles(); } else { modelTrainMngCoreService.markStep1Success(modelId); - modelTestMetricsJobService.findTestValidMetricCsvFiles(); + modelTrainMetricsJobService.findTrainValidMetricCsvFiles(); } } else { -- 2.49.1 From d42e1afbd40f00b4ffb7c934a6a31b6a76e271e9 Mon Sep 17 00:00:00 2001 From: "gayoun.park" Date: Thu, 12 Feb 2026 21:51:53 +0900 Subject: [PATCH 2/2] =?UTF-8?q?=EC=8A=A4=EC=BC=80=EC=A4=84=EB=9F=AC=20api?= =?UTF-8?q?=20=EC=88=98=EB=8F=99=20=ED=98=B8=EC=B6=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../model/ModelTrainMngApiController.java | 45 +++++++++++++++++++ 1 file changed, 45 insertions(+) diff --git a/src/main/java/com/kamco/cd/training/model/ModelTrainMngApiController.java b/src/main/java/com/kamco/cd/training/model/ModelTrainMngApiController.java index c6fd192..8068bd0 100644 --- a/src/main/java/com/kamco/cd/training/model/ModelTrainMngApiController.java +++ b/src/main/java/com/kamco/cd/training/model/ModelTrainMngApiController.java @@ -8,6 +8,8 @@ import com.kamco.cd.training.model.dto.ModelConfigDto; import com.kamco.cd.training.model.dto.ModelTrainMngDto; import com.kamco.cd.training.model.dto.ModelTrainMngDto.Basic; import com.kamco.cd.training.model.service.ModelTrainMngService; +import com.kamco.cd.training.train.service.ModelTestMetricsJobService; +import com.kamco.cd.training.train.service.ModelTrainMetricsJobService; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.media.Content; @@ -16,6 +18,7 @@ import io.swagger.v3.oas.annotations.responses.ApiResponse; import io.swagger.v3.oas.annotations.responses.ApiResponses; import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.validation.Valid; +import java.io.IOException; import java.util.List; import java.util.UUID; import lombok.RequiredArgsConstructor; @@ -35,6 +38,8 @@ import org.springframework.web.bind.annotation.RestController; @RequestMapping("/api/models") public class ModelTrainMngApiController { private final ModelTrainMngService modelTrainMngService; + private final ModelTrainMetricsJobService modelTrainMetricsJobService; + private final ModelTestMetricsJobService modelTestMetricsJobService; @Operation(summary = "모델학습 목록 조회", description = "모델학습 목록 조회 API") @ApiResponses( @@ -167,4 +172,44 @@ public class ModelTrainMngApiController { public ApiResponseDto findModelStep1InProgressCnt() { return ApiResponseDto.ok(modelTrainMngService.findModelStep1InProgressCnt()); } + + @Operation( + summary = "스케줄러 findTrainValidMetricCsvFiles", + description = "스케줄러 findTrainValidMetricCsvFiles") + @ApiResponses( + value = { + @ApiResponse( + responseCode = "200", + description = "검색 성공", + content = + @Content( + mediaType = "application/json", + schema = @Schema(implementation = Long.class))), + @ApiResponse(responseCode = "400", description = "잘못된 검색 조건", content = @Content), + @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content) + }) + @GetMapping("/schedule-trainvalid") + public ApiResponseDto findTrainValidMetricCsvFiles() { + modelTrainMetricsJobService.findTrainValidMetricCsvFiles(); + return ApiResponseDto.ok(null); + } + + @Operation(summary = "스케줄러 findTestMetricCsvFiles", description = "스케줄러 findTestMetricCsvFiles") + @ApiResponses( + value = { + @ApiResponse( + responseCode = "200", + description = "검색 성공", + content = + @Content( + mediaType = "application/json", + schema = @Schema(implementation = Long.class))), + @ApiResponse(responseCode = "400", description = "잘못된 검색 조건", content = @Content), + @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content) + }) + @GetMapping("/schedule-test") + public ApiResponseDto findTestValidMetricCsvFiles() throws IOException { + modelTestMetricsJobService.findTestValidMetricCsvFiles(); + return ApiResponseDto.ok(null); + } } -- 2.49.1