Skip to content

Commit 6d3450d

Browse files
committed
Apply DataConverter to results of .getLastFailure
1 parent 2237e72 commit 6d3450d

2 files changed

Lines changed: 5 additions & 6 deletions

File tree

temporal-sdk/src/main/java/io/temporal/client/ActivityExecutionDescription.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -132,8 +132,10 @@ public Instant getLastStartedTime() {
132132

133133
/** Failure details from the last failed attempt. {@code null} if no failure has occurred. */
134134
@Nullable
135-
public io.temporal.api.failure.v1.Failure getLastFailure() {
136-
return info().hasLastFailure() ? info().getLastFailure() : null;
135+
public Exception getLastFailure() {
136+
return info().hasLastFailure()
137+
? dataConverter.failureToException(info().getLastFailure())
138+
: null;
137139
}
138140

139141
/** Identity of the worker that last processed this activity. */

temporal-sdk/src/test/java/io/temporal/client/functional/StandaloneActivityTest.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
import io.temporal.api.enums.v1.ActivityExecutionStatus;
1515
import io.temporal.api.enums.v1.ActivityIdConflictPolicy;
1616
import io.temporal.api.enums.v1.ActivityIdReusePolicy;
17-
import io.temporal.api.failure.v1.Failure;
1817
import io.temporal.client.*;
1918
import io.temporal.common.RetryOptions;
2019
import io.temporal.common.interceptors.ActivityClientCallsInterceptor;
@@ -816,12 +815,10 @@ public void testDescribeLastFailureIsPopulatedDuringRetryBackoff() {
816815
Duration.ofSeconds(60),
817816
() -> {
818817
ActivityExecutionDescription desc = handle.describe();
819-
Failure lastFailure = desc.getLastFailure();
818+
Exception lastFailure = desc.getLastFailure();
820819
assertNotNull("last_failure should be set after a failed attempt", lastFailure);
821820
assertEquals("deliberate failure", lastFailure.getMessage());
822-
// raw info must agree with the typed accessor
823821
assertTrue(desc.getRawInfo().hasLastFailure());
824-
assertEquals(lastFailure, desc.getRawInfo().getLastFailure());
825822
});
826823
} finally {
827824
try {

0 commit comments

Comments
 (0)