Skip to content

Commit fa5185d

Browse files
committed
Address review comments
1 parent 5f6f1c5 commit fa5185d

File tree

2 files changed

+5
-18
lines changed

2 files changed

+5
-18
lines changed

temporal-test-server/src/main/java/io/temporal/internal/testservice/StateMachines.java

Lines changed: 1 addition & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -807,20 +807,6 @@ private static void timeoutNexusOperation(
807807
"Timeout type not supported for Nexus operations: " + timeoutType);
808808
}
809809

810-
String timeoutMessage;
811-
switch (timeoutType) {
812-
case TIMEOUT_TYPE_SCHEDULE_TO_START:
813-
timeoutMessage = "operation timed out before starting";
814-
break;
815-
case TIMEOUT_TYPE_START_TO_CLOSE:
816-
timeoutMessage = "operation timed out after starting";
817-
break;
818-
case TIMEOUT_TYPE_SCHEDULE_TO_CLOSE:
819-
default:
820-
timeoutMessage = "operation timed out";
821-
break;
822-
}
823-
824810
Failure failure =
825811
Failure.newBuilder()
826812
.setMessage("nexus operation completed unsuccessfully")
@@ -833,7 +819,7 @@ private static void timeoutNexusOperation(
833819
.setScheduledEventId(data.scheduledEventId))
834820
.setCause(
835821
Failure.newBuilder()
836-
.setMessage(timeoutMessage)
822+
.setMessage("operation timed out")
837823
.setTimeoutFailureInfo(
838824
TimeoutFailureInfo.newBuilder().setTimeoutType(timeoutType)))
839825
.build();

temporal-test-server/src/test/java/io/temporal/testserver/functional/NexusWorkflowTest.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import io.temporal.internal.testservice.NexusTaskToken;
2626
import io.temporal.testing.internal.SDKTestWorkflowRule;
2727
import io.temporal.testserver.functional.common.TestWorkflows;
28+
import java.time.Duration;
2829
import java.util.Arrays;
2930
import java.util.List;
3031
import java.util.UUID;
@@ -745,7 +746,7 @@ public void testNexusOperationScheduleToStartTimeout() {
745746
Assert.assertTrue("OPERATION_TIMEOUT should be positive", operationTimeoutMs > 0);
746747

747748
// Sleep longer than schedule-to-start timeout to trigger the timeout
748-
Thread.sleep(2000);
749+
testWorkflowRule.sleep(Duration.ofSeconds(2);)
749750
} catch (Exception e) {
750751
Assert.fail(e.getMessage());
751752
}
@@ -763,7 +764,7 @@ public void testNexusOperationScheduleToStartTimeout() {
763764
assertOperationFailureInfo(failure.getNexusOperationExecutionFailureInfo());
764765
Assert.assertEquals("nexus operation completed unsuccessfully", failure.getMessage());
765766
io.temporal.api.failure.v1.Failure cause = failure.getCause();
766-
Assert.assertEquals("operation timed out before starting", cause.getMessage());
767+
Assert.assertEquals("operation timed out", cause.getMessage());
767768
Assert.assertTrue(cause.hasTimeoutFailureInfo());
768769
Assert.assertEquals(
769770
TimeoutType.TIMEOUT_TYPE_SCHEDULE_TO_START, cause.getTimeoutFailureInfo().getTimeoutType());
@@ -833,7 +834,7 @@ public void testNexusOperationStartToCloseTimeout() {
833834
assertOperationFailureInfo(operationId, failure.getNexusOperationExecutionFailureInfo());
834835
Assert.assertEquals("nexus operation completed unsuccessfully", failure.getMessage());
835836
io.temporal.api.failure.v1.Failure cause = failure.getCause();
836-
Assert.assertEquals("operation timed out after starting", cause.getMessage());
837+
Assert.assertEquals("operation timed out", cause.getMessage());
837838
Assert.assertTrue(cause.hasTimeoutFailureInfo());
838839
Assert.assertEquals(
839840
TimeoutType.TIMEOUT_TYPE_START_TO_CLOSE, cause.getTimeoutFailureInfo().getTimeoutType());

0 commit comments

Comments
 (0)