Skip to content

Commit 1394620

Browse files
authored
Merge branch 'dev' into Fix-17817-2
2 parents 3bc41d5 + 46f0f3c commit 1394620

12 files changed

Lines changed: 874 additions & 20 deletions

File tree

.github/workflows/api-test.yml

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,8 @@ jobs:
119119
class: org.apache.dolphinscheduler.api.test.cases.GrpcTaskAPITest
120120
- name: OidcLoginAPITest
121121
class: org.apache.dolphinscheduler.api.test.cases.OidcLoginAPITest
122+
- name: DependentTaskAPITest
123+
class: org.apache.dolphinscheduler.api.test.cases.tasks.DependentTaskAPITest
122124
env:
123125
RECORDING_PATH: /tmp/recording-${{ matrix.case.name }}
124126
steps:
@@ -138,7 +140,7 @@ jobs:
138140
path: ~/.m2/repository
139141
key: ${{ runner.os }}-maven-${{ hashFiles('**/pom.xml') }}-api-test
140142
restore-keys: ${{ runner.os }}-maven-
141-
- uses: actions/download-artifact@v4
143+
- uses: actions/download-artifact@v8
142144
name: Download Docker Images
143145
with:
144146
name: standalone-image-api-test

.github/workflows/backend.yml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ jobs:
121121
submodules: true
122122
- name: Collect Workflow Metrics
123123
uses: ./.github/actions/actions-workflow-metrics
124-
- uses: actions/download-artifact@v4
124+
- uses: actions/download-artifact@v8
125125
name: Download Binary Package
126126
with:
127127
# Only run cluster test on jdk8
@@ -151,7 +151,7 @@ jobs:
151151
- name: Collect Workflow Metrics
152152
uses: ./.github/actions/actions-workflow-metrics
153153
- name: Download Binary Package
154-
uses: actions/download-artifact@v4
154+
uses: actions/download-artifact@v8
155155
with:
156156
name: binary-package-8
157157
path: ds_schema_check_test/dev

.github/workflows/codeql.yaml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,12 @@ jobs:
3838

3939
steps:
4040
- name: Checkout repository
41-
uses: actions/checkout@v3
41+
uses: actions/checkout@v6
4242
with:
4343
submodules: true
4444

4545
- name: Initialize CodeQL
46-
uses: github/codeql-action/init@v2
46+
uses: github/codeql-action/init@v4
4747
with:
4848
languages: java
4949
queries: +security-and-quality
@@ -55,4 +55,4 @@ jobs:
5555
-Prelease
5656
5757
- name: Perform CodeQL Analysis
58-
uses: github/codeql-action/analyze@v2
58+
uses: github/codeql-action/analyze@v4

.github/workflows/docs.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ jobs:
4242
steps:
4343
- uses: actions/checkout@v6
4444
- name: Set up Python 3.9
45-
uses: actions/setup-python@v2
45+
uses: actions/setup-python@v6
4646
with:
4747
python-version: 3.9
4848
- name: Run Dev Relative Reference

.github/workflows/frontend.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ jobs:
6868
name: Sanity Check
6969
uses: ./.github/actions/sanity-check
7070
- name: Set up Node.js
71-
uses: actions/setup-node@v2
71+
uses: actions/setup-node@v6
7272
with:
7373
node-version: 16
7474
- name: Code Format Check

dolphinscheduler-api-test/dolphinscheduler-api-test-case/src/test/java/org/apache/dolphinscheduler/api/test/cases/tasks/DependentTaskAPITest.java

Lines changed: 353 additions & 0 deletions
Large diffs are not rendered by default.

dolphinscheduler-api-test/dolphinscheduler-api-test-case/src/test/java/org/apache/dolphinscheduler/api/test/pages/workflow/WorkflowDefinitionPage.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,11 +48,18 @@ public HttpResponse createWorkflowDefinition(User loginUser,
4848
long projectCode,
4949
File file,
5050
String workflowDefinitionName) {
51+
String fileContent = new String(Files.readAllBytes(file.toPath()), StandardCharsets.UTF_8);
52+
return createWorkflowDefinition(loginUser, projectCode, fileContent, workflowDefinitionName);
53+
}
54+
55+
public HttpResponse createWorkflowDefinition(User loginUser,
56+
long projectCode,
57+
String jsonContent,
58+
String workflowDefinitionName) {
5159
Map<String, Object> params = new HashMap<>();
5260
params.put("loginUser", loginUser);
5361

54-
String fileContent = new String(Files.readAllBytes(file.toPath()), StandardCharsets.UTF_8);
55-
Map<String, Object> fileContentMap = JSONUtils.parseObject(fileContent, new TypeReference<>() {
62+
Map<String, Object> fileContentMap = JSONUtils.parseObject(jsonContent, new TypeReference<>() {
5663
});
5764
if (fileContentMap == null) {
5865
throw new RuntimeException("file content parse error");
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,64 @@
1+
{
2+
"taskDefinitionJson": [
3+
{
4+
"code": 264597693773601,
5+
"delayTime": "0",
6+
"description": "",
7+
"environmentCode": -1,
8+
"failRetryInterval": "1",
9+
"failRetryTimes": "0",
10+
"flag": "YES",
11+
"name": "dependent_failed_test",
12+
"taskParams": {
13+
"localParams": [],
14+
"resourceList": [],
15+
"dependence": {
16+
"relation": "AND",
17+
"dependTaskList": [
18+
{
19+
"relation": "AND",
20+
"dependItemList": [
21+
{
22+
"projectCode": ${projectCode},
23+
"definitionCode": 999999999999,
24+
"depTaskCode": 0,
25+
"cycle": "day",
26+
"dateValue": "today",
27+
"dependentType": "DEPENDENT_ON_WORKFLOW"
28+
}
29+
]
30+
}
31+
],
32+
"checkInterval": 10,
33+
"failurePolicy": "DEPENDENT_FAILURE_FAILURE",
34+
"failureWaitingTime": 1
35+
}
36+
},
37+
"taskPriority": "MEDIUM",
38+
"taskType": "DEPENDENT",
39+
"timeout": 0,
40+
"timeoutFlag": "CLOSE",
41+
"timeoutNotifyStrategy": "",
42+
"workerGroup": "default",
43+
"cpuQuota": -1,
44+
"memoryMax": -1,
45+
"taskExecuteType": "BATCH"
46+
}
47+
],
48+
"taskRelationJson": [
49+
{
50+
"name": "",
51+
"preTaskCode": 0,
52+
"preTaskVersion": 0,
53+
"postTaskCode": 264597693773601,
54+
"postTaskVersion": 0,
55+
"conditionType": "NONE",
56+
"conditionParams": {}
57+
}
58+
],
59+
"name": "dependentFailedWorkflow",
60+
"executionType": "PARALLEL",
61+
"description": "",
62+
"globalParams": [],
63+
"timeout": 0
64+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,64 @@
1+
{
2+
"taskDefinitionJson": [
3+
{
4+
"code": 264597693773600,
5+
"delayTime": "0",
6+
"description": "",
7+
"environmentCode": -1,
8+
"failRetryInterval": "1",
9+
"failRetryTimes": "0",
10+
"flag": "YES",
11+
"name": "dependent_success_test",
12+
"taskParams": {
13+
"localParams": [],
14+
"resourceList": [],
15+
"dependence": {
16+
"relation": "AND",
17+
"dependTaskList": [
18+
{
19+
"relation": "AND",
20+
"dependItemList": [
21+
{
22+
"projectCode": ${projectCode},
23+
"definitionCode": ${definitionCode},
24+
"depTaskCode": 0,
25+
"cycle": "day",
26+
"dateValue": "today",
27+
"dependentType": "DEPENDENT_ON_WORKFLOW"
28+
}
29+
]
30+
}
31+
],
32+
"checkInterval": 10,
33+
"failurePolicy": "DEPENDENT_FAILURE_FAILURE",
34+
"failureWaitingTime": 1
35+
}
36+
},
37+
"taskPriority": "MEDIUM",
38+
"taskType": "DEPENDENT",
39+
"timeout": 0,
40+
"timeoutFlag": "CLOSE",
41+
"timeoutNotifyStrategy": "",
42+
"workerGroup": "default",
43+
"cpuQuota": -1,
44+
"memoryMax": -1,
45+
"taskExecuteType": "BATCH"
46+
}
47+
],
48+
"taskRelationJson": [
49+
{
50+
"name": "",
51+
"preTaskCode": 0,
52+
"preTaskVersion": 0,
53+
"postTaskCode": 264597693773600,
54+
"postTaskVersion": 0,
55+
"conditionType": "NONE",
56+
"conditionParams": {}
57+
}
58+
],
59+
"name": "dependentSuccessWorkflow",
60+
"executionType": "PARALLEL",
61+
"description": "",
62+
"globalParams": [],
63+
"timeout": 0
64+
}

0 commit comments

Comments
 (0)