shp 파일 생성중 오류 발생시 중지되게 수정 #144
@@ -104,6 +104,7 @@ public class ExternalJarRunner {
|
|||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("jar execution error. output=\n{}", out, 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 ExternalJarRunner externalJarRunner;
|
||||||
private final ShpKeyLock shpKeyLock;
|
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")
|
@Async("shpExecutor")
|
||||||
public void runPipeline(String jarPath, String datasetDir, String batchIds, String inferenceId) {
|
public void runPipeline(String jarPath, String datasetDir, String batchIds, String inferenceId) {
|
||||||
//
|
|
||||||
// batchIds.split(",")
|
|
||||||
// inferenceResultCoreService.getInferenceResultCnt();
|
|
||||||
|
|
||||||
// inferenceId 기준 동시 실행 제한
|
// inferenceId 기준 동시 실행 제한
|
||||||
if (!shpKeyLock.tryLock(inferenceId)) {
|
if (!shpKeyLock.tryLock(inferenceId)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user