shp 파일 생성중 오류 발생시 중지되게 수정 #144
@@ -104,6 +104,7 @@ public class ExternalJarRunner {
|
||||
|
||||
} catch (Exception e) {
|
||||
log.error("jar execution error. output=\n{}", out, e);
|
||||
throw new RuntimeException("jar execution error\n" + out, e);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -18,11 +18,16 @@ public class ShpPipelineService {
|
||||
private final ExternalJarRunner externalJarRunner;
|
||||
private final ShpKeyLock shpKeyLock;
|
||||
|
||||
/**
|
||||
* shp 파일 생성 1. merge 생성 2. 생성된 merge shp 파일로 geoserver 등록, 3.도엽별로 shp 생성
|
||||
*
|
||||
* @param jarPath 실행 jar 파일 경로
|
||||
* @param datasetDir shp 파일이 생성될 경로
|
||||
* @param batchIds 추론 batch id = 12,13,14
|
||||
* @param inferenceId 추론 uid 32자
|
||||
*/
|
||||
@Async("shpExecutor")
|
||||
public void runPipeline(String jarPath, String datasetDir, String batchIds, String inferenceId) {
|
||||
//
|
||||
// batchIds.split(",")
|
||||
// inferenceResultCoreService.getInferenceResultCnt();
|
||||
|
||||
// inferenceId 기준 동시 실행 제한
|
||||
if (!shpKeyLock.tryLock(inferenceId)) {
|
||||
|
||||
Reference in New Issue
Block a user