Skip to content

Commit 1173afd

Browse files
support to execute AppConn2Linkis and bml2linkis node type.
1 parent bf7a7be commit 1173afd

File tree

1 file changed

+3
-4
lines changed
  • dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/execution/impl

1 file changed

+3
-4
lines changed

dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/execution/impl/LinkisNodeExecutionImpl.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,7 @@
2121
import com.webank.wedatasphere.dss.linkis.node.execution.execution.LinkisNodeExecution;
2222
import com.webank.wedatasphere.dss.linkis.node.execution.job.Job;
2323
import com.webank.wedatasphere.dss.linkis.node.execution.listener.LinkisExecutionListener;
24-
import com.webank.wedatasphere.dss.linkis.node.execution.parser.CodeParser;
25-
import com.webank.wedatasphere.dss.linkis.node.execution.parser.JobParamsParser;
26-
import com.webank.wedatasphere.dss.linkis.node.execution.parser.JobParser;
27-
import com.webank.wedatasphere.dss.linkis.node.execution.parser.JobRuntimeParamsParser;
24+
import com.webank.wedatasphere.dss.linkis.node.execution.parser.*;
2825
import com.webank.wedatasphere.dss.linkis.node.execution.service.LinkisURLService;
2926
import com.webank.wedatasphere.dss.linkis.node.execution.service.impl.BuildJobActionImpl;
3027
import com.webank.wedatasphere.dss.linkis.node.execution.utils.LinkisJobExecutionUtils;
@@ -59,6 +56,8 @@ private LinkisNodeExecutionImpl() {
5956
registerJobParser(new CodeParser());
6057
registerJobParser(new JobRuntimeParamsParser());
6158
registerJobParser(new JobParamsParser());
59+
registerJobParser(new BML2LinkisJobParser());
60+
registerJobParser(new AppConn2LinkisJobParser());
6261
}
6362

6463
public static LinkisNodeExecution getLinkisNodeExecution() {

0 commit comments

Comments
 (0)