Skip to content

Commit 0d05f72

Browse files
committed
fix tests
1 parent 10c3930 commit 0d05f72

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

client/src/test/java/com/microsoft/durabletask/IntegrationTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,7 @@ void longTimer() throws TimeoutException {
114114

115115
DurableTaskClient client = new DurableTaskGrpcClientBuilder().build();
116116
try (worker; client) {
117+
client.createTaskHub(true);
117118
String instanceId = client.scheduleNewOrchestrationInstance(orchestratorName);
118119
Duration timeout = delay.plus(defaultTimeout);
119120
OrchestrationMetadata instance = client.waitForInstanceCompletion(instanceId, timeout, false);
@@ -896,7 +897,7 @@ void multiInstanceQuery() throws TimeoutException{
896897
result = client.queryInstances(query);
897898
assertTrue(result.getOrchestrationState().isEmpty());
898899

899-
query.setCreatedTimeFrom(sequencesFinishedTime.minus(Duration.ofSeconds(3)));
900+
query.setCreatedTimeFrom(sequencesFinishedTime.minus(Duration.ofSeconds(5)));
900901
result = client.queryInstances(query);
901902
assertEquals(5, result.getOrchestrationState().stream()
902903
.filter(state -> state.getInstanceId().contains("sequence"))

0 commit comments

Comments
 (0)