리커버리 수정 테스트,,
This commit is contained in:
@@ -443,7 +443,7 @@ public class ModelTrainMngCoreService {
|
|||||||
.orElseThrow(() -> new IllegalArgumentException("Model not found: " + modelId));
|
.orElseThrow(() -> new IllegalArgumentException("Model not found: " + modelId));
|
||||||
|
|
||||||
master.setStatusCd(TrainStatusType.STOPPED.getId());
|
master.setStatusCd(TrainStatusType.STOPPED.getId());
|
||||||
master.setStep2State(TrainStatusType.STOPPED.getId());
|
master.setStep1State(TrainStatusType.STOPPED.getId());
|
||||||
master.setLastError(errorMessage);
|
master.setLastError(errorMessage);
|
||||||
master.setUpdatedUid(userUtil.getId());
|
master.setUpdatedUid(userUtil.getId());
|
||||||
master.setUpdatedDttm(ZonedDateTime.now());
|
master.setUpdatedDttm(ZonedDateTime.now());
|
||||||
|
|||||||
@@ -157,6 +157,7 @@ public class JobRecoveryOnStartupService {
|
|||||||
modelTrainJobCoreService.markPaused(
|
modelTrainJobCoreService.markPaused(
|
||||||
job.getId(), modelId, "AUTO_KILLED_ON_SERVER_RESTART");
|
job.getId(), modelId, "AUTO_KILLED_ON_SERVER_RESTART");
|
||||||
|
|
||||||
|
log.info("job = {}", job);
|
||||||
markStepStopByJobType(job, "AUTO_KILLED_ON_SERVER_RESTART");
|
markStepStopByJobType(job, "AUTO_KILLED_ON_SERVER_RESTART");
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
|
|||||||
Reference in New Issue
Block a user