Skip to content

Commit 5c313d6

Browse files
committed
add a wait after starting a workflow
1 parent d436444 commit 5c313d6

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

tests/src/test/java/io/orkes/conductor/client/WorkflowRetryTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,12 +12,14 @@
1212
*/
1313
package io.orkes.conductor.client;
1414

15+
import java.time.Duration;
1516
import java.util.*;
1617

1718
import org.junit.jupiter.api.Assertions;
1819
import org.junit.jupiter.api.DisplayName;
1920
import org.junit.jupiter.api.Test;
2021

22+
import com.google.common.util.concurrent.Uninterruptibles;
2123
import com.netflix.conductor.common.metadata.tasks.TaskDef;
2224
import com.netflix.conductor.common.metadata.tasks.TaskResult;
2325
import com.netflix.conductor.common.metadata.workflow.StartWorkflowRequest;
@@ -58,6 +60,7 @@ public void testRetry() {
5860
startWorkflowRequest.setVersion(1);
5961
startWorkflowRequest.setInput(new HashMap<>());
6062
String workflowId = workflowClient.startWorkflow(startWorkflowRequest);
63+
Uninterruptibles.sleepUninterruptibly(Duration.ofMillis(100));
6164
Workflow workflow = workflowClient.getWorkflow(workflowId, true);
6265

6366
String taskId = workflow.getTasks().get(0).getTaskId();

0 commit comments

Comments
 (0)