File tree Expand file tree Collapse file tree 6 files changed +49
-83
lines changed
java/io/serverlessworkflow/api
src/main/java/io/serverlessworkflow/impl Expand file tree Collapse file tree 6 files changed +49
-83
lines changed Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ public class FeaturesTest {
45
45
"features/try.yaml",
46
46
"features/listen.yaml",
47
47
"features/callFunction.yaml",
48
- "features/callCustomFunction.json "
48
+ "features/callCustomFunction.yaml "
49
49
})
50
50
public void testSpecFeaturesParsing(String workflowLocation) throws IOException {
51
51
Workflow workflow = readWorkflowFromClasspath(workflowLocation);
Load Diff This file was deleted.
Original file line number Diff line number Diff line change
1
+ document:
2
+ dsl: 1.0.0-alpha5
3
+ namespace: test
4
+ name: call-example
5
+ version: 0.1.0
6
+ schedule:
7
+ cron: 0 8 * * *
8
+ do:
9
+ - getData:
10
+ call: http
11
+ with:
12
+ method: get
13
+ endpoint: https://api.agify.io?name=meelad
14
+ output:
15
+ as: ".data.reading"
16
+ - filterData:
17
+ for:
18
+ in: ".data.reading"
19
+ each: reading
20
+ do:
21
+ - log:
22
+ call: https://raw.githubusercontent.com/serverlessworkflow/catalog/main/functions/log/1.0.0/function.yaml
23
+ with:
24
+ level: information
25
+ format: "{TIMESTAMP} [{LEVEL}] ({CONTEXT}): {MESSAGE}"
26
+ message: Hello, world!
27
+ timestamp: true
Original file line number Diff line number Diff line change 25
25
<artifactId>jersey-media-json-jackson</artifactId>
26
26
<version>${version.org.glassfish.jersey}</version>
27
27
</dependency>
28
- <dependency>
29
- <groupId>org.junit.jupiter</groupId>
30
- <artifactId>junit-jupiter-api</artifactId>
31
- <scope>test</scope>
32
- </dependency>
33
- <dependency>
34
- <groupId>org.junit.jupiter</groupId>
35
- <artifactId>junit-jupiter-engine</artifactId>
36
- <scope>test</scope>
37
- </dependency>
38
- <dependency>
39
- <groupId>org.junit.jupiter</groupId>
40
- <artifactId>junit-jupiter-params</artifactId>
41
- <scope>test</scope>
42
- </dependency>
43
- <dependency>
44
- <groupId>org.assertj</groupId>
45
- <artifactId>assertj-core</artifactId>
46
- <scope>test</scope>
47
- </dependency>
28
+ <dependency>
29
+ <groupId>org.junit.jupiter</groupId>
30
+ <artifactId>junit-jupiter-api</artifactId>
31
+ <scope>test</scope>
32
+ </dependency>
33
+ <dependency>
34
+ <groupId>org.junit.jupiter</groupId>
35
+ <artifactId>junit-jupiter-engine</artifactId>
36
+ <scope>test</scope>
37
+ </dependency>
38
+ <dependency>
39
+ <groupId>org.junit.jupiter</groupId>
40
+ <artifactId>junit-jupiter-params</artifactId>
41
+ <scope>test</scope>
42
+ </dependency>
43
+ <dependency>
44
+ <groupId>org.assertj</groupId>
45
+ <artifactId>assertj-core</artifactId>
46
+ <scope>test</scope>
47
+ </dependency>
48
48
</dependencies>
49
49
<build>
50
50
<plugins>
Original file line number Diff line number Diff line change @@ -40,8 +40,8 @@ public HttpExecutor(CallHTTP task) {
40
40
41
41
@Override
42
42
protected JsonNode internalExecute(JsonNode node) {
43
-
44
43
HTTPArguments httpArgs = task.getWith();
44
+ // missing checks
45
45
String uri =
46
46
httpArgs
47
47
.getEndpoint()
Original file line number Diff line number Diff line change 29
29
import java.util.Map;
30
30
import java.util.concurrent.ConcurrentHashMap;
31
31
32
- /*
33
- * Copyright 2020-Present The Serverless Workflow Specification Authors
34
- *
35
- * Licensed under the Apache License, Version 2.0 (the "License");
36
- * you may not use this file except in compliance with the License.
37
- * You may obtain a copy of the License at
38
- *
39
- * http://www.apache.org/licenses/LICENSE-2.0
40
- *
41
- * Unless required by applicable law or agreed to in writing, software
42
- * distributed under the License is distributed on an "AS IS" BASIS,
43
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
44
- * See the License for the specific language governing permissions and
45
- * limitations under the License.
46
- */
47
32
public class WorkflowDefinition {
48
33
49
34
private WorkflowDefinition(Workflow workflow, Collection<WorkflowExecutionListener> listeners) {
You can’t perform that action at this time.
0 commit comments