File tree Expand file tree Collapse file tree 4 files changed +8
-1
lines changed
lib/src/main/java/com/palantir/computemodules Expand file tree Collapse file tree 4 files changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -7,7 +7,7 @@ buildscript {
7
7
dependencies {
8
8
classpath ' com.palantir.gradle.jdkslatest:gradle-jdks-latest:0.15.0'
9
9
classpath ' com.palantir.jakartapackagealignment:jakarta-package-alignment:0.6.0'
10
- classpath ' com.palantir.baseline:gradle-baseline-java:6.25 .0'
10
+ classpath ' com.palantir.baseline:gradle-baseline-java:6.29 .0'
11
11
classpath ' com.palantir.gradle.consistentversions:gradle-consistent-versions:2.27.0'
12
12
classpath ' com.palantir.gradle.gitversion:gradle-git-version:3.2.0'
13
13
classpath ' com.palantir.javaformat:gradle-palantir-java-format:2.62.0'
Original file line number Diff line number Diff line change 32
32
import com .palantir .computemodules .functions .serde .DefaultDeserializer ;
33
33
import com .palantir .computemodules .functions .serde .DefaultSerializer ;
34
34
import com .palantir .logsafe .SafeArg ;
35
+ import com .palantir .logsafe .Unsafe ;
35
36
import com .palantir .logsafe .exceptions .SafeRuntimeException ;
36
37
import com .palantir .logsafe .logger .SafeLogger ;
37
38
import com .palantir .logsafe .logger .SafeLoggerFactory ;
@@ -90,6 +91,7 @@ public void onFailure(Throwable throwable) {
90
91
}
91
92
}
92
93
94
+ @ Unsafe
93
95
private Result execute (ComputeModuleJob job ) {
94
96
if (functions .containsKey (job .queryType ())) {
95
97
return functions .get (job .queryType ()).run (new Context (job .jobId ()), job .query ());
Original file line number Diff line number Diff line change 20
20
import com .palantir .computemodules .functions .results .Result ;
21
21
import com .palantir .computemodules .functions .serde .Deserializer ;
22
22
import com .palantir .computemodules .functions .serde .Serializer ;
23
+ import com .palantir .logsafe .Unsafe ;
23
24
import java .io .InputStream ;
24
25
25
26
public final class FunctionRunner <I , O > {
@@ -42,6 +43,7 @@ public FunctionRunner(
42
43
this .serializer = serializer ;
43
44
}
44
45
46
+ @ Unsafe
45
47
public Result run (Context context , Object input ) {
46
48
I deserializedInput = deserializer .deserialize (input , inputType );
47
49
try {
Original file line number Diff line number Diff line change 15
15
*/
16
16
package com .palantir .computemodules .functions .results ;
17
17
18
+ import com .palantir .logsafe .Unsafe ;
19
+
20
+ @ Unsafe
18
21
public sealed interface Result permits Ok , Failed {}
You can’t perform that action at this time.
0 commit comments