Skip to content

Commit 3b0435b

Browse files
wushengyeyouyawushengyeyouya
committed
Add dss-workflow module, which is a frequently Orchestrator implementation.
1 parent c163fc1 commit 3b0435b

File tree

211 files changed

+16608
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

211 files changed

+16608
-0
lines changed

‎dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/pom.xml‎

Lines changed: 226 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,226 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<!--
3+
~ Copyright 2019 WeBank
4+
~ Licensed under the Apache License, Version 2.0 (the "License");
5+
~ you may not use this file except in compliance with the License.
6+
~ You may obtain a copy of the License at
7+
~
8+
~ http://www.apache.org/licenses/LICENSE-2.0
9+
~
10+
~ Unless required by applicable law or agreed to in writing, software
11+
~ distributed under the License is distributed on an "AS IS" BASIS,
12+
~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
~ See the License for the specific language governing permissions and
14+
~ limitations under the License.
15+
~
16+
-->
17+
18+
<project xmlns="http://maven.apache.org/POM/4.0.0"
19+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
20+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
21+
<parent>
22+
<artifactId>dss</artifactId>
23+
<groupId>com.webank.wedatasphere.dss</groupId>
24+
<version>1.0.0</version>
25+
</parent>
26+
<modelVersion>4.0.0</modelVersion>
27+
28+
<artifactId>dss-flow-execution-server</artifactId>
29+
30+
<dependencies>
31+
32+
<dependency>
33+
<groupId>com.webank.wedatasphere.linkis</groupId>
34+
<artifactId>linkis-jobhistory</artifactId>
35+
<version>${linkis.version}</version>
36+
</dependency>
37+
<dependency>
38+
<groupId>com.webank.wedatasphere.linkis</groupId>
39+
<artifactId>linkis-entrance</artifactId>
40+
<version>${linkis.version}</version>
41+
<exclusions>
42+
<exclusion>
43+
<artifactId>linkis-common</artifactId>
44+
<groupId>com.webank.wedatasphere.linkis</groupId>
45+
</exclusion>
46+
<exclusion>
47+
<artifactId>spring-tx</artifactId>
48+
<groupId>org.springframework</groupId>
49+
</exclusion>
50+
<exclusion>
51+
<artifactId>commons-text</artifactId>
52+
<groupId>org.apache.commons</groupId>
53+
</exclusion>
54+
<exclusion>
55+
<artifactId>json4s-jackson_2.11</artifactId>
56+
<groupId>org.json4s</groupId>
57+
</exclusion>
58+
<exclusion>
59+
<artifactId>linkis-label-common</artifactId>
60+
<groupId>com.webank.wedatasphere.linkis</groupId>
61+
</exclusion>
62+
</exclusions>
63+
</dependency>
64+
65+
<dependency>
66+
<groupId>com.webank.wedatasphere.dss</groupId>
67+
<artifactId>dss-linkis-node-execution</artifactId>
68+
<version>${dss.version}</version>
69+
<exclusions>
70+
<exclusion>
71+
<artifactId>linkis-common</artifactId>
72+
<groupId>com.webank.wedatasphere.linkis</groupId>
73+
</exclusion>
74+
<exclusion>
75+
<artifactId>commons-beanutils</artifactId>
76+
<groupId>commons-beanutils</groupId>
77+
</exclusion>
78+
<exclusion>
79+
<artifactId>linkis-label-common</artifactId>
80+
<groupId>com.webank.wedatasphere.linkis</groupId>
81+
</exclusion>
82+
</exclusions>
83+
</dependency>
84+
85+
<dependency>
86+
<groupId>com.webank.wedatasphere.linkis</groupId>
87+
<artifactId>linkis-rpc</artifactId>
88+
<version>${linkis.version}</version>
89+
<scope>provided</scope>
90+
<exclusions>
91+
<exclusion>
92+
<groupId>org.springframework.cloud</groupId>
93+
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
94+
</exclusion>
95+
<exclusion>
96+
<groupId>javax.validation</groupId>
97+
<artifactId>validation-api</artifactId>
98+
</exclusion>
99+
<exclusion>
100+
<groupId>org.glassfish.hk2.external</groupId>
101+
<artifactId>bean-validator</artifactId>
102+
</exclusion>
103+
</exclusions>
104+
</dependency>
105+
106+
<dependency>
107+
<groupId>com.webank.wedatasphere.linkis</groupId>
108+
<artifactId>linkis-storage</artifactId>
109+
<version>${linkis.version}</version>
110+
<scope>provided</scope>
111+
</dependency>
112+
<dependency>
113+
<groupId>com.webank.wedatasphere.dss</groupId>
114+
<artifactId>dss-workflow-sdk</artifactId>
115+
<version>${dss.version}</version>
116+
</dependency>
117+
118+
119+
<dependency>
120+
<groupId>com.webank.wedatasphere.linkis</groupId>
121+
<artifactId>linkis-mybatis</artifactId>
122+
<version>${linkis.version}</version>
123+
<scope>provided</scope>
124+
</dependency>
125+
126+
<dependency>
127+
<groupId>com.webank.wedatasphere.dss</groupId>
128+
<artifactId>dss-common</artifactId>
129+
<version>${dss.version}</version>
130+
<scope>provided</scope>
131+
</dependency>
132+
133+
<dependency>
134+
<groupId>com.webank.wedatasphere.dss</groupId>
135+
<artifactId>dss-sso-integration-standard</artifactId>
136+
<version>${dss.version}</version>
137+
</dependency>
138+
139+
<dependency>
140+
<groupId>org.apache.commons</groupId>
141+
<artifactId>commons-lang3</artifactId>
142+
<version>${commons.lang3.version}</version>
143+
<scope>provided</scope>
144+
</dependency>
145+
146+
147+
</dependencies>
148+
149+
<build>
150+
<plugins>
151+
<plugin>
152+
<groupId>org.apache.maven.plugins</groupId>
153+
<artifactId>maven-compiler-plugin</artifactId>
154+
<version>3.2</version>
155+
<configuration>
156+
<source>1.8</source>
157+
<target>1.8</target>
158+
<encoding>UTF-8</encoding>
159+
</configuration>
160+
</plugin>
161+
<plugin>
162+
<groupId>org.apache.maven.plugins</groupId>
163+
<artifactId>maven-deploy-plugin</artifactId>
164+
</plugin>
165+
166+
<plugin>
167+
<groupId>net.alchim31.maven</groupId>
168+
<artifactId>scala-maven-plugin</artifactId>
169+
<configuration>
170+
<addScalacArgs>-target:jvm-1.8</addScalacArgs>
171+
</configuration>
172+
</plugin>
173+
<plugin>
174+
<groupId>org.apache.maven.plugins</groupId>
175+
<artifactId>maven-jar-plugin</artifactId>
176+
</plugin>
177+
<plugin>
178+
<groupId>org.apache.maven.plugins</groupId>
179+
<artifactId>maven-assembly-plugin</artifactId>
180+
<version>2.3</version>
181+
<inherited>false</inherited>
182+
<executions>
183+
<execution>
184+
<id>make-assembly</id>
185+
<phase>package</phase>
186+
<goals>
187+
<goal>single</goal>
188+
</goals>
189+
<configuration>
190+
<descriptors>
191+
<descriptor>src/main/assembly/distribution.xml</descriptor>
192+
</descriptors>
193+
</configuration>
194+
</execution>
195+
</executions>
196+
<configuration>
197+
<skipAssembly>false</skipAssembly>
198+
<finalName>out</finalName>
199+
<appendAssemblyId>false</appendAssemblyId>
200+
<attach>false</attach>
201+
<descriptors>
202+
<descriptor>src/main/assembly/distribution.xml</descriptor>
203+
</descriptors>
204+
</configuration>
205+
</plugin>
206+
</plugins>
207+
<resources>
208+
<resource>
209+
<directory>src/main/java</directory>
210+
<includes>
211+
<include>**/*.xml</include>
212+
</includes>
213+
</resource>
214+
<!-- <resource>
215+
<directory>src/main/resources</directory>
216+
<includes>
217+
<include>**/*.xml</include>
218+
<include>**/*.properties</include>
219+
<include>**/*.yml</include>
220+
</includes>
221+
</resource>-->
222+
</resources>
223+
<finalName>${project.artifactId}-${project.version}</finalName>
224+
</build>
225+
226+
</project>

‎dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/src/main/assembly/distribution.xml‎

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
<!--
2+
~ Copyright 2019 WeBank
3+
~ Licensed under the Apache License, Version 2.0 (the "License");
4+
~ you may not use this file except in compliance with the License.
5+
~ You may obtain a copy of the License at
6+
~
7+
~ http://www.apache.org/licenses/LICENSE-2.0
8+
~
9+
~ Unless required by applicable law or agreed to in writing, software
10+
~ distributed under the License is distributed on an "AS IS" BASIS,
11+
~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
~ See the License for the specific language governing permissions and
13+
~ limitations under the License.
14+
~
15+
-->
16+
17+
<assembly
18+
xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/2.3"
19+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
20+
xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/2.3 http://maven.apache.org/xsd/assembly-1.1.2.xsd">
21+
<id>dss-framework-execution-server</id>
22+
<formats>
23+
<format>dir</format>
24+
</formats>
25+
<includeBaseDirectory>true</includeBaseDirectory>
26+
<baseDirectory>dss-flow-execution-server</baseDirectory>
27+
28+
<dependencySets>
29+
<dependencySet>
30+
<!-- Enable access to all projects in the current multimodule build! <useAllReactorProjects>true</useAllReactorProjects> -->
31+
<!-- Now, select which projects to include in this module-set. -->
32+
<outputDirectory>lib</outputDirectory>
33+
<useProjectArtifact>true</useProjectArtifact>
34+
<useTransitiveDependencies>true</useTransitiveDependencies>
35+
<unpack>false</unpack>
36+
<useStrictFiltering>true</useStrictFiltering>
37+
<useTransitiveFiltering>true</useTransitiveFiltering>
38+
39+
</dependencySet>
40+
</dependencySets>
41+
42+
</assembly>
43+

‎dss-orchestrator/orchestrators/dss-workflow/dss-flow-execution-server/src/main/java/com/webank/wedatasphere/dss/flow/execution/entrance/dao/TaskMapper.java‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
/*
2+
* Copyright 2019 WeBank
3+
* Licensed under the Apache License, Version 2.0 (the "License");
4+
* you may not use this file except in compliance with the License.
5+
* You may obtain a copy of the License at
6+
*
7+
* http://www.apache.org/licenses/LICENSE-2.0
8+
*
9+
* Unless required by applicable law or agreed to in writing, software
10+
* distributed under the License is distributed on an "AS IS" BASIS,
11+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
* See the License for the specific language governing permissions and
13+
* limitations under the License.
14+
*
15+
*/
16+
17+
package com.webank.wedatasphere.dss.flow.execution.entrance.dao;
18+
19+
import com.webank.wedatasphere.dss.flow.execution.entrance.entity.WorkflowQueryTask;
20+
import org.apache.ibatis.annotations.Param;
21+
import java.util.Date;
22+
import java.util.List;
23+
24+
25+
public interface TaskMapper {
26+
27+
List<WorkflowQueryTask> selectTask(WorkflowQueryTask queryTask);
28+
29+
void insertTask(WorkflowQueryTask queryTask);
30+
31+
void updateTask(WorkflowQueryTask queryTask);
32+
33+
List<WorkflowQueryTask> search(@Param("taskID") Long taskID, @Param("umUser") String username, @Param("status") List<String> status,
34+
@Param("startDate") Date startDate, @Param("endDate") Date endDate, @Param("executeApplicationName") String executeApplicationName,
35+
@Param("instance") String instance, @Param("execId") String execId);
36+
37+
String selectTaskStatusForUpdate(Long taskID);
38+
39+
}

0 commit comments

Comments
 (0)