remove scheduler client

WeBankBlockchain · Oct 28, 2024 · 0a84767 · 0a84767
1 parent a64475d
commit 0a84767
Show file tree

Hide file tree

Showing 7 changed files with 0 additions and 387 deletions.
diff --git a/...scheduler/src/main/java/com/webank/wedpr/components/scheduler/api/SchedulerClientApi.java b/...scheduler/src/main/java/com/webank/wedpr/components/scheduler/api/SchedulerClientApi.java
diff --git a/...scheduler/src/main/java/com/webank/wedpr/components/scheduler/client/SchedulerClient.java b/...scheduler/src/main/java/com/webank/wedpr/components/scheduler/client/SchedulerClient.java
diff --git a/...ler/src/main/java/com/webank/wedpr/components/scheduler/config/SchedulerClientConfig.java b/...ler/src/main/java/com/webank/wedpr/components/scheduler/config/SchedulerClientConfig.java
diff --git a/...scheduler/src/main/java/com/webank/wedpr/components/scheduler/config/SchedulerLoader.java b/...scheduler/src/main/java/com/webank/wedpr/components/scheduler/config/SchedulerLoader.java
@@ -132,29 +132,6 @@ protected void registerExecutors(
                         new ExecutiveContextBuilder(projectMapperWrapper),
                         threadPoolService);
         executorManager.registerExecutor(ExecutorType.DAG.getType(), dagSchedulerExecutor);
-        /*
-        boolean enableLocalDagScheduler = true;
-        if (enableLocalDagScheduler) {
-            DagSchedulerExecutor dagSchedulerExecutor =
-                    new DagSchedulerExecutor(
-                            loadBalancer,
-                            jobWorkerMapper,
-                            jobChecker,
-                            storage,
-                            fileMetaBuilder,
-                            executorManager);
-            executorManager.registerExecutor(ExecutorType.REMOTE.getType(), dagSchedulerExecutor);
-        } else {
-            SchedulerClient schedulerClient = new SchedulerClient();
-            RemoteSchedulerExecutor remoteSchedulerExecutor =
-                    new RemoteSchedulerExecutor(
-                            schedulerClient, jobChecker, storage, fileMetaBuilder);
-
-            executorManager.registerExecutor(
-                    ExecutorType.REMOTE.getType(), remoteSchedulerExecutor);
-        }
-        */
-
         /*
         // register the executor
         PSIExecutor psiExecutor = new PSIExecutor(storage, fileMetaBuilder, jobChecker);

diff --git a/...er/src/main/java/com/webank/wedpr/components/scheduler/executor/impl/mpc/MPCJobParam.java b/...er/src/main/java/com/webank/wedpr/components/scheduler/executor/impl/mpc/MPCJobParam.java
@@ -6,7 +6,6 @@
 import com.webank.wedpr.common.utils.Common;
 import com.webank.wedpr.common.utils.ObjectMapperFactory;
 import com.webank.wedpr.common.utils.WeDPRException;
-import com.webank.wedpr.components.scheduler.client.SchedulerClient;
 import com.webank.wedpr.components.scheduler.executor.impl.model.DatasetInfo;
 import com.webank.wedpr.components.scheduler.executor.impl.model.FileMeta;
 import com.webank.wedpr.components.scheduler.executor.impl.model.FileMetaBuilder;

diff --git a/...a/com/webank/wedpr/components/scheduler/executor/impl/remote/RemoteSchedulerExecutor.java b/...a/com/webank/wedpr/components/scheduler/executor/impl/remote/RemoteSchedulerExecutor.java