mvn spotless:apply #andy

OpenSPG · Jan 10, 2025 · a25f0f5 · a25f0f5
1 parent eb3c097
commit a25f0f5
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 17 deletions.
diff --git a/...ain/java/com/antgroup/openspg/server/core/scheduler/service/task/TaskExecuteTemplate.java b/...ain/java/com/antgroup/openspg/server/core/scheduler/service/task/TaskExecuteTemplate.java
@@ -12,9 +12,6 @@
  */
 package com.antgroup.openspg.server.core.scheduler.service.task;
 
-import java.util.Date;
-import java.util.List;
-
 import com.antgroup.openspg.common.util.DateTimeUtils;
 import com.antgroup.openspg.server.common.model.exception.SchedulerException;
 import com.antgroup.openspg.server.common.model.scheduler.SchedulerEnum.InstanceStatus;
@@ -26,6 +23,8 @@
 import com.antgroup.openspg.server.core.scheduler.service.common.SchedulerCommonService;
 import com.antgroup.openspg.server.core.scheduler.service.metadata.SchedulerTaskService;
 import com.antgroup.openspg.server.core.scheduler.service.utils.SchedulerUtils;
+import java.util.Date;
+import java.util.List;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -56,7 +55,8 @@ public final void executeEntry(TaskExecuteContext context) {
       }
     } catch (Throwable e) {
       context.getTask().setStatus(TaskStatus.ERROR);
-      context.addTraceLog("Scheduler execute failed with error:%s", ExceptionUtils.getStackTrace(e));
+      context.addTraceLog(
+          "Scheduler execute failed with error:%s", ExceptionUtils.getStackTrace(e));
       log.error("JobTask process error uniqueId:{}", context.getInstance().getUniqueId(), e);
     }
 
@@ -183,7 +183,8 @@ private void startNextNode(
     updateTask.setId(nextTask.getId());
     String name = nextNode.getName();
     if (!TaskStatus.WAIT.equals(nextTask.getStatus())) {
-      context.addTraceLog("current status of %s is %s, and can not be modified", name, nextTask.getStatus());
+      context.addTraceLog(
+          "current status of %s is %s, and can not be modified", name, nextTask.getStatus());
       return;
     }
     updateTask.setStatus(TaskStatus.RUNNING);

diff --git a/...group/openspg/server/core/scheduler/service/task/async/builder/KagAlignmentAsyncTask.java b/...group/openspg/server/core/scheduler/service/task/async/builder/KagAlignmentAsyncTask.java
@@ -228,7 +228,8 @@ public List<SubGraphRecord> alignment(
                   ? 0
                   : subGraphRecord.getResultEdges().size();
 
-          addTraceLog("Alignment operator was invoked successfully nodes:%s edges:%s", nodes, edges);
+          addTraceLog(
+              "Alignment operator was invoked successfully nodes:%s edges:%s", nodes, edges);
         }
       }
       return subGraphList;

diff --git a/...tgroup/openspg/server/core/scheduler/service/task/async/builder/KagSplitterAsyncTask.java b/...tgroup/openspg/server/core/scheduler/service/task/async/builder/KagSplitterAsyncTask.java
@@ -12,13 +12,9 @@
  */
 package com.antgroup.openspg.server.core.scheduler.service.task.async.builder;
 
-import java.util.List;
-import java.util.Map;
-
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.TypeReference;
-
 import com.antgroup.openspg.builder.model.record.ChunkRecord;
 import com.antgroup.openspg.cloudext.interfaces.objectstorage.ObjectStorageClient;
 import com.antgroup.openspg.cloudext.interfaces.objectstorage.ObjectStorageClientDriverManager;
@@ -43,6 +39,8 @@
 import com.antgroup.openspg.server.core.scheduler.service.task.async.AsyncTaskExecuteTemplate;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.collect.Lists;
+import java.util.List;
+import java.util.Map;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 

diff --git a/...antgroup/openspg/server/core/scheduler/service/task/async/builder/KagWriterAsyncTask.java b/...antgroup/openspg/server/core/scheduler/service/task/async/builder/KagWriterAsyncTask.java
@@ -12,15 +12,8 @@
  */
 package com.antgroup.openspg.server.core.scheduler.service.task.async.builder;
 
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
-import java.util.concurrent.atomic.AtomicLong;
-
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.TypeReference;
-
 import com.antgroup.openspg.builder.core.runtime.BuilderContext;
 import com.antgroup.openspg.builder.model.pipeline.config.Neo4jSinkNodeConfig;
 import com.antgroup.openspg.builder.model.record.RecordAlterOperationEnum;
@@ -42,6 +35,11 @@
 import com.antgroup.openspg.server.core.scheduler.service.task.async.AsyncTaskExecuteTemplate;
 import com.antgroup.openspg.server.core.scheduler.service.utils.SchedulerUtils;
 import com.google.common.collect.Lists;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.atomic.AtomicLong;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;