Fixed workflow misspelling (#246)

Author: mfateev

src/main/java/com/uber/cadence/internal/replay/ReplayDecider.java

@@ -55,7 +55,7 @@
 import org.slf4j.LoggerFactory;
 
 /**
- * Implements decider that relies on replay of a worklfow code. An instance of this class is created
+ * Implements decider that relies on replay of a workflow code. An instance of this class is created
  * per decision.
  */
 class ReplayDecider implements Decider {

src/main/java/com/uber/cadence/internal/sync/WorkflowThreadImpl.java

@@ -253,7 +253,7 @@ public void start() {
     } catch (RejectedExecutionException e) {
       throw new Error(
           "Not enough threads to execute workflows. "
-              + "If this message appears consistently either WorkerOptions.maxConcurrentWorklfowExecutionSize "
+              + "If this message appears consistently either WorkerOptions.maxConcurrentWorkflowExecutionSize "
               + "should be decreased or WorkerOptions.maxWorkflowThreads increased.");
     }
   }

src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableState.java

@@ -81,10 +81,10 @@ void failDecisionTask(RespondDecisionTaskFailedRequest request)
   void childWorkflowStarted(ChildWorkflowExecutionStartedEventAttributes a)
       throws InternalServiceError, EntityNotExistsError, BadRequestError;
 
-  void childWorklfowFailed(String workflowId, ChildWorkflowExecutionFailedEventAttributes a)
+  void childWorkflowFailed(String workflowId, ChildWorkflowExecutionFailedEventAttributes a)
       throws InternalServiceError, EntityNotExistsError, BadRequestError;
 
-  void childWorklfowTimedOut(String activityId, ChildWorkflowExecutionTimedOutEventAttributes a)
+  void childWorkflowTimedOut(String activityId, ChildWorkflowExecutionTimedOutEventAttributes a)
       throws InternalServiceError, EntityNotExistsError, BadRequestError;
 
   void failStartChildWorkflow(String workflowId, StartChildWorkflowExecutionFailedEventAttributes a)

src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java

@@ -677,7 +677,7 @@ public void childWorkflowStarted(ChildWorkflowExecutionStartedEventAttributes a)
   }
 
   @Override
-  public void childWorklfowFailed(String activityId, ChildWorkflowExecutionFailedEventAttributes a)
+  public void childWorkflowFailed(String activityId, ChildWorkflowExecutionFailedEventAttributes a)
       throws InternalServiceError, EntityNotExistsError, BadRequestError {
     update(
         ctx -> {
@@ -690,7 +690,7 @@ public void childWorklfowFailed(String activityId, ChildWorkflowExecutionFailedE
   }
 
   @Override
-  public void childWorklfowTimedOut(
+  public void childWorkflowTimedOut(
       String activityId, ChildWorkflowExecutionTimedOutEventAttributes a)
       throws InternalServiceError, EntityNotExistsError, BadRequestError {
     update(
@@ -846,7 +846,7 @@ private void processFailWorkflowExecution(
                 try {
                   parent
                       .get()
-                      .childWorklfowFailed(ctx.getExecutionId().getWorkflowId().getWorkflowId(), a);
+                      .childWorkflowFailed(ctx.getExecutionId().getWorkflowId().getWorkflowId(), a);
                 } catch (EntityNotExistsError entityNotExistsError) {
                   // Parent might already close
                 } catch (BadRequestError | InternalServiceError e) {
@@ -1296,7 +1296,7 @@ private void reportWorkflowTimeoutToParent(RequestContext ctx) {
               .setWorkflowType(startRequest.getWorkflowType())
               .setDomain(ctx.getDomain())
               .setWorkflowExecution(ctx.getExecution());
-      parent.get().childWorklfowTimedOut(ctx.getExecutionId().getWorkflowId().getWorkflowId(), a);
+      parent.get().childWorkflowTimedOut(ctx.getExecutionId().getWorkflowId().getWorkflowId(), a);
     } catch (EntityNotExistsError entityNotExistsError) {
       // Parent might already close
     } catch (BadRequestError | InternalServiceError e) {

src/main/java/com/uber/cadence/worker/Worker.java

@@ -160,7 +160,7 @@ private static SingleWorkerOptions toWorkflowOptions(
         .setPollerOptions(options.getWorkflowPollerOptions())
         .setReportCompletionRetryOptions(options.getReportWorkflowCompletionRetryOptions())
         .setReportFailureRetryOptions(options.getReportWorkflowFailureRetryOptions())
-        .setTaskExecutorThreadPoolSize(options.getMaxConcurrentWorklfowExecutionSize())
+        .setTaskExecutorThreadPoolSize(options.getMaxConcurrentWorkflowExecutionSize())
         .setMetricsScope(options.getMetricsScope().tagged(tags))
         .setEnableLoggingInReplay(options.getEnableLoggingInReplay())
         .build();

src/main/java/com/uber/cadence/worker/WorkerOptions.java

@@ -38,7 +38,7 @@ public static final class Builder {
     private String identity;
     private DataConverter dataConverter = JsonDataConverter.getInstance();
     private int maxConcurrentActivityExecutionSize = 100;
-    private int maxConcurrentWorklfowExecutionSize = 50;
+    private int maxConcurrentWorkflowExecutionSize = 50;
     private PollerOptions activityPollerOptions;
     private PollerOptions workflowPollerOptions;
     private RetryOptions reportActivityCompletionRetryOptions;
@@ -111,12 +111,12 @@ public Builder setMaxConcurrentActivityExecutionSize(int maxConcurrentActivityEx
     }
 
     /** Maximum number of parallely executed decision tasks. */
-    public Builder setMaxConcurrentWorklfowExecutionSize(int maxConcurrentWorklfowExecutionSize) {
-      if (maxConcurrentWorklfowExecutionSize <= 0) {
+    public Builder setMaxConcurrentWorkflowExecutionSize(int maxConcurrentWorkflowExecutionSize) {
+      if (maxConcurrentWorkflowExecutionSize <= 0) {
         throw new IllegalArgumentException(
-            "Negative or zero: " + maxConcurrentWorklfowExecutionSize);
+            "Negative or zero: " + maxConcurrentWorkflowExecutionSize);
       }
-      this.maxConcurrentWorklfowExecutionSize = maxConcurrentWorklfowExecutionSize;
+      this.maxConcurrentWorkflowExecutionSize = maxConcurrentWorkflowExecutionSize;
       return this;
     }
 
@@ -190,7 +190,7 @@ public WorkerOptions build() {
           identity,
           dataConverter,
           maxConcurrentActivityExecutionSize,
-          maxConcurrentWorklfowExecutionSize,
+          maxConcurrentWorkflowExecutionSize,
           activityPollerOptions,
           workflowPollerOptions,
           reportActivityCompletionRetryOptions,
@@ -209,7 +209,7 @@ public WorkerOptions build() {
   private final String identity;
   private final DataConverter dataConverter;
   private final int maxConcurrentActivityExecutionSize;
-  private final int maxConcurrentWorklfowExecutionSize;
+  private final int maxConcurrentWorkflowExecutionSize;
   private final PollerOptions activityPollerOptions;
   private final PollerOptions workflowPollerOptions;
   private final RetryOptions reportActivityCompletionRetryOptions;
@@ -227,7 +227,7 @@ private WorkerOptions(
       String identity,
       DataConverter dataConverter,
       int maxConcurrentActivityExecutionSize,
-      int maxConcurrentWorklfowExecutionSize,
+      int maxConcurrentWorkflowExecutionSize,
       PollerOptions activityPollerOptions,
       PollerOptions workflowPollerOptions,
       RetryOptions reportActivityCompletionRetryOptions,
@@ -243,7 +243,7 @@ private WorkerOptions(
     this.identity = identity;
     this.dataConverter = dataConverter;
     this.maxConcurrentActivityExecutionSize = maxConcurrentActivityExecutionSize;
-    this.maxConcurrentWorklfowExecutionSize = maxConcurrentWorklfowExecutionSize;
+    this.maxConcurrentWorkflowExecutionSize = maxConcurrentWorkflowExecutionSize;
     this.activityPollerOptions = activityPollerOptions;
     this.workflowPollerOptions = workflowPollerOptions;
     this.reportActivityCompletionRetryOptions = reportActivityCompletionRetryOptions;
@@ -279,8 +279,8 @@ public int getMaxConcurrentActivityExecutionSize() {
     return maxConcurrentActivityExecutionSize;
   }
 
-  public int getMaxConcurrentWorklfowExecutionSize() {
-    return maxConcurrentWorklfowExecutionSize;
+  public int getMaxConcurrentWorkflowExecutionSize() {
+    return maxConcurrentWorkflowExecutionSize;
   }
 
   public PollerOptions getActivityPollerOptions() {

src/main/java/com/uber/cadence/workflow/Workflow.java

@@ -739,7 +739,7 @@ public static boolean isReplaying() {
    * failure. The decision task after timeout is rescheduled and re-executed giving SideEffect
    * another chance to succeed.
    *
-   * <p>Caution: do not use sideEffect function to modify any worklfow sate. Only use the
+   * <p>Caution: do not use sideEffect function to modify any workflow sate. Only use the
    * SideEffect's return value. For example this code is BROKEN:
    *
    * <pre><code>
@@ -793,7 +793,7 @@ public static <R> R sideEffect(Class<R> resultClass, Func<R> func) {
    * failure. The decision task after timeout is rescheduled and re-executed giving SideEffect
    * another chance to succeed.
    *
-   * <p>Caution: do not use sideEffect function to modify any worklfow sate. Only use the
+   * <p>Caution: do not use sideEffect function to modify any workflow sate. Only use the
    * SideEffect's return value. For example this code is BROKEN:
    *
    * <pre><code>

src/test/java/com/uber/cadence/internal/testing/WorkflowTestingTest.java

@@ -608,7 +608,7 @@ public interface ChildWorkflow {
     String workflow(String input, String parentId);
   }
 
-  public static class ChildWorklfowImpl implements ChildWorkflow {
+  public static class ChildWorkflowImpl implements ChildWorkflow {
 
     @Override
     public String workflow(String input, String parentId) {
@@ -622,7 +622,7 @@ public String workflow(String input, String parentId) {
   @Test
   public void testChild() {
     Worker worker = testEnvironment.newWorker(TASK_LIST);
-    worker.registerWorkflowImplementationTypes(ChildWorklfowImpl.class, ParentWorkflowImpl.class);
+    worker.registerWorkflowImplementationTypes(ChildWorkflowImpl.class, ParentWorkflowImpl.class);
     testEnvironment.start();
     WorkflowClient client = testEnvironment.newWorkflowClient();
     WorkflowOptions options = new WorkflowOptions.Builder().setWorkflowId("parent1").build();
@@ -645,7 +645,7 @@ public String workflow(String input) {
     public void signal(String value) {}
   }
 
-  public static class SimulatedTimeoutChildWorklfow implements ChildWorkflow {
+  public static class SimulatedTimeoutChildWorkflow implements ChildWorkflow {
 
     @Override
     public String workflow(String input, String parentId) {
@@ -658,7 +658,7 @@ public String workflow(String input, String parentId) {
   public void testChildSimulatedTimeout() throws Throwable {
     Worker worker = testEnvironment.newWorker(TASK_LIST);
     worker.registerWorkflowImplementationTypes(
-        SimulatedTimeoutParentWorkflow.class, SimulatedTimeoutChildWorklfow.class);
+        SimulatedTimeoutParentWorkflow.class, SimulatedTimeoutChildWorkflow.class);
     testEnvironment.start();
     WorkflowClient client = testEnvironment.newWorkflowClient();
     WorkflowOptions options = new WorkflowOptions.Builder().setWorkflowId("parent1").build();