Resume feature about adapting to create workflow when have not scheduler.

Author: zqburde

dss-framework/dss-framework-orchestrator-server/src/main/java/com/webank/wedatasphere/dss/orchestrator/server/service/impl/OrchestratorFrameworkServiceImpl.java

@@ -185,7 +185,7 @@ private <K extends StructureRequestRef, V extends ResponseRef> V tryOrchestratio
         Long refProjectId, refOrchestrationId;
         if (askProjectSender) {
             ProjectRefIdResponse projectRefIdResponse = RpcAskUtils.processAskException(DSSSenderServiceFactory.getOrCreateServiceInstance().getProjectServerSender()
-                    .ask(new ProjectRefIdRequest(orchestrationPair.getValue().getId(), dssOrchestrator.getProjectId())), ProjectRefIdResponse.class, ProjectRefIdRequest.class);
+                    .ask(new ProjectRefIdRequest(Optional.ofNullable(orchestrationPair).map(ImmutablePair::getValue).map(AppInstance::getId).orElse(null), dssOrchestrator.getProjectId())), ProjectRefIdResponse.class, ProjectRefIdRequest.class);
            refProjectId = projectRefIdResponse.getRefProjectId();
             refOrchestrationId = null;
         } else {
@@ -378,11 +378,12 @@ protected ImmutablePair<OrchestrationService, AppInstance> getOrchestrationServi
             dssOrchestratorInfo.setLinkedAppConnNames(dssOrchestrator.getLinkedAppConn().stream().map(appConn -> appConn.getAppDesc().getAppName()).collect(Collectors.toList()));
         }
         SchedulerAppConn appConn = dssOrchestrator.getSchedulerAppConn();
-        if (appConn == null) {
-            throw new ExternalOperationWarnException(50322, "DSSOrchestrator " + dssOrchestrator.getName() + " has no SchedulerAppConn.");
+        if (appConn != null) {
+            AppInstance appInstance = appConn.getAppDesc().getAppInstances().get(0);
+            return new ImmutablePair<>(appConn.getOrCreateStructureStandard().getOrchestrationService(appInstance), appInstance);
+        } else {
+            return new ImmutablePair<>(null, null);
         }
-        AppInstance appInstance = appConn.getAppDesc().getAppInstances().get(0);
-        return new ImmutablePair<>(appConn.getOrCreateStructureStandard().getOrchestrationService(appInstance), appInstance);
     }
 
     /**

dss-framework/dss-framework-orchestrator-server/src/main/java/com/webank/wedatasphere/dss/orchestrator/server/service/impl/OrchestratorServiceImpl.java

@@ -17,6 +17,7 @@
 package com.webank.wedatasphere.dss.orchestrator.server.service.impl;
 
 import com.google.common.collect.Lists;
+import com.webank.wedatasphere.dss.appconn.core.AppConn;
 import com.webank.wedatasphere.dss.common.constant.project.ProjectUserPrivEnum;
 import com.webank.wedatasphere.dss.common.exception.DSSErrorException;
 import com.webank.wedatasphere.dss.common.label.DSSLabel;
@@ -58,6 +59,7 @@
 import com.webank.wedatasphere.dss.standard.app.development.service.RefQueryService;
 import com.webank.wedatasphere.dss.standard.app.development.standard.DevelopmentIntegrationStandard;
 import com.webank.wedatasphere.dss.standard.app.sso.Workspace;
+import com.webank.wedatasphere.dss.standard.common.desc.AppDesc;
 import com.webank.wedatasphere.dss.standard.common.desc.AppInstance;
 import com.webank.wedatasphere.dss.standard.common.entity.ref.ResponseRef;
 import com.webank.wedatasphere.dss.standard.common.exception.operation.ExternalOperationWarnException;
@@ -123,7 +125,9 @@ public OrchestratorVo createOrchestrator(String userName,
                     Map<String, Object> dssJobContent = MapUtils.newCommonMapBuilder()
                             .put(OrchestratorRefConstant.DSS_ORCHESTRATOR_INFO_KEY, dssOrchestratorInfo)
                             .put(OrchestratorRefConstant.ORCHESTRATOR_VERSION_KEY, version)
-                            .put(OrchestratorRefConstant.ORCHESTRATION_SCHEDULER_APP_CONN, dssOrchestrator.getSchedulerAppConn().getAppDesc().getAppName()).build();
+                            .put(OrchestratorRefConstant.ORCHESTRATION_SCHEDULER_APP_CONN, Optional.ofNullable(dssOrchestrator)
+                                    .map(DSSOrchestrator::getSchedulerAppConn).map(AppConn::getAppDesc).map(AppDesc::getAppName)
+                                    .map(Object::toString).orElse("NULL")).build();
                     DSSJobContentRequestRef requestRef = (DSSJobContentRequestRef) developmentRequestRef;
                     requestRef.setDSSJobContent(dssJobContent);
                     return ((RefCreationOperation) developmentOperation).createRef(requestRef);

dss-orchestrator/dss-orchestrator-loader/src/main/java/com/webank/wedatasphere/dss/orchestrator/loader/DefaultOrchestratorLoader.java

@@ -66,7 +66,7 @@ protected DSSOrchestratorContext createOrchestratorContext() {
         if (appConnList.stream().anyMatch(t -> t instanceof SchedulerAppConn)) {
             List<SchedulerAppConn> schedulerAppConns = AppConnManager.getAppConnManager().listAppConns(SchedulerAppConn.class);
             SchedulerAppConn schedulerAppConn;
-            if(StringUtils.isBlank(relation.getBindingSchedulerAppConnName())) {
+            if (StringUtils.isBlank(relation.getBindingSchedulerAppConnName())) {
                 schedulerAppConn = schedulerAppConns.get(0);
             } else {
                 schedulerAppConn = schedulerAppConns.stream().filter(appConn1 -> appConn1.getAppDesc().getAppName().equals(relation.getBindingSchedulerAppConnName()))