parent
aef400e67f
commit
83eef96c0f
|
|
@ -69,7 +69,6 @@ public class SchedulerCoreService {
|
|||
|
||||
// 1. cron 판단
|
||||
if (!shouldRun(job.getSjcId(), job.getSjcCronExpression(), now)) {
|
||||
System.out.println(job.getSjcJobCode() + " shouldRun is false");
|
||||
return;
|
||||
}
|
||||
|
||||
|
|
@ -77,7 +76,6 @@ public class SchedulerCoreService {
|
|||
if (Boolean.TRUE.equals(job.getSjcEnabled())
|
||||
&& logService.isRunning(job.getSjcId())) {
|
||||
log.info("Job already running. jobCode={}", job.getSjcJobCode());
|
||||
System.out.println("Job already running. jobCode=" + job.getSjcJobCode());
|
||||
return;
|
||||
}
|
||||
|
||||
|
|
@ -100,7 +98,6 @@ public class SchedulerCoreService {
|
|||
|
||||
// 5. worker 실행
|
||||
try {
|
||||
System.out.println(job.getSjcJobCode() + " worker start");
|
||||
executeWorker(job, from, to, runningLog);
|
||||
} catch (Exception e) {
|
||||
logService.markFailed(
|
||||
|
|
@ -151,7 +148,6 @@ public class SchedulerCoreService {
|
|||
);
|
||||
|
||||
ScheduleWorkerResponseDto body = response.getBody();
|
||||
System.out.println("response: "+body);
|
||||
if (body == null) {
|
||||
throw new IllegalStateException("Worker response is null");
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue