Default schedule to start timeout (#239)

temporalio · Oct 30, 2020 · 4b03019 · 4b03019
1 parent a1de809
commit 4b03019
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/temporal-sdk/src/main/java/io/temporal/worker/WorkerFactoryOptions.java b/temporal-sdk/src/main/java/io/temporal/worker/WorkerFactoryOptions.java
@@ -41,6 +41,7 @@ public static WorkerFactoryOptions getDefaultInstance() {
   private static final int DEFAULT_HOST_LOCAL_WORKFLOW_POLL_THREAD_COUNT = 5;
   private static final int DEFAULT_WORKFLOW_CACHE_SIZE = 600;
   private static final int DEFAULT_MAX_WORKFLOW_THREAD_COUNT = 600;
+  private static final Duration DEFAULT_STICKY_SCHEDULE_TO_START_TIMEOUT = Duration.ofSeconds(5);
 
   private static final WorkerFactoryOptions DEFAULT_INSTANCE;
 
@@ -49,6 +50,7 @@ public static WorkerFactoryOptions getDefaultInstance() {
   }
 
   public static class Builder {
+
     private Duration workflowHostLocalTaskQueueScheduleToStartTimeout;
     private int workflowCacheSize;
     private int maxWorkflowThreadCount;
@@ -185,6 +187,9 @@ private WorkerFactoryOptions(
             !workflowHostLocalTaskQueueScheduleToStartTimeout.isNegative(),
             "negative workflowHostLocalTaskQueueScheduleToStartTimeoutSeconds");
       }
+      if (workflowHostLocalTaskQueueScheduleToStartTimeout == null) {
+        workflowHostLocalTaskQueueScheduleToStartTimeout = DEFAULT_STICKY_SCHEDULE_TO_START_TIMEOUT;
+      }
       if (workflowInterceptors == null) {
         workflowInterceptors = new WorkflowInterceptor[0];
       }

diff --git a/temporal-sdk/src/test/java/io/temporal/workflow/WorkflowTest.java b/temporal-sdk/src/test/java/io/temporal/workflow/WorkflowTest.java
@@ -325,6 +325,7 @@ public WorkflowStub newUntypedWorkflowStub(
         WorkerFactoryOptions.newBuilder()
             .setWorkflowInterceptors(tracer)
             .setActivityInterceptors(activityInterceptor)
+            .setWorkflowHostLocalTaskQueueScheduleToStartTimeout(Duration.ZERO)
             .setWorkflowHostLocalTaskQueueScheduleToStartTimeout(
                 versionTest ? Duration.ZERO : Duration.ofSeconds(10))
             .build();