mvn spotless:apply #andy

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

Hide file tree

Showing 5 changed files with 10 additions and 8 deletions.
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
@@ -93,7 +93,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res
     SchedulerTask task = memoryTaskServer.getTask(resource);
     SchedulerTask schedulerTask = context.getTask();
     if (task == null) {
-      context.addTraceLog("Splitter task not found, recreate it");
+      context.addTraceLog("Splitter task not found, recreating……");
       submit(context);
       return SchedulerEnum.TaskStatus.RUNNING;
     }

diff --git a/...group/openspg/server/core/scheduler/service/task/async/builder/KagExtractorAsyncTask.java b/...group/openspg/server/core/scheduler/service/task/async/builder/KagExtractorAsyncTask.java
@@ -129,7 +129,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res
     SchedulerTask task = memoryTaskServer.getTask(resource);
     SchedulerTask schedulerTask = context.getTask();
     if (task == null) {
-      context.addTraceLog("Extractor task not found, recreate it");
+      context.addTraceLog("Extractor task not found, recreating……");
       submit(context);
       return SchedulerEnum.TaskStatus.RUNNING;
     }

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
@@ -94,7 +94,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res
     SchedulerTask task = memoryTaskServer.getTask(resource);
     SchedulerTask schedulerTask = context.getTask();
     if (task == null) {
-      context.addTraceLog("Splitter task not found, recreate it");
+      context.addTraceLog("Splitter task not found, recreating……");
       submit(context);
       return SchedulerEnum.TaskStatus.RUNNING;
     }

diff --git a/...roup/openspg/server/core/scheduler/service/task/async/builder/KagVectorizerAsyncTask.java b/...roup/openspg/server/core/scheduler/service/task/async/builder/KagVectorizerAsyncTask.java
@@ -12,9 +12,14 @@
  */
 package com.antgroup.openspg.server.core.scheduler.service.task.async.builder;
 
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicLong;
+
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.TypeReference;
+
 import com.antgroup.openspg.builder.model.record.SubGraphRecord;
 import com.antgroup.openspg.cloudext.interfaces.objectstorage.ObjectStorageClient;
 import com.antgroup.openspg.cloudext.interfaces.objectstorage.ObjectStorageClientDriverManager;
@@ -39,9 +44,6 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.atomic.AtomicLong;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -98,7 +100,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res
     SchedulerTask task = memoryTaskServer.getTask(resource);
     SchedulerTask schedulerTask = context.getTask();
     if (task == null) {
-      context.addTraceLog("Vectorizer task not found, recreate it");
+      context.addTraceLog("Vectorizer task not found, recreating……");
       submit(context);
       return SchedulerEnum.TaskStatus.RUNNING;
     }

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
@@ -96,7 +96,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res
     SchedulerTask task = memoryTaskServer.getTask(resource);
     SchedulerTask schedulerTask = context.getTask();
     if (task == null) {
-      context.addTraceLog("Writer task not found, recreate it");
+      context.addTraceLog("Writer task not found, recreating……");
       submit(context);
       return SchedulerEnum.TaskStatus.RUNNING;
     }