Renamed task list to task queue (#138)

* Updated protos

* renamed task list to task queue

Author: mfateev

src/main/java/io/temporal/activity/ActivityOptions.java

@@ -58,7 +58,7 @@ public static final class Builder {
 
     private Duration startToCloseTimeout;
 
-    private String taskList;
+    private String taskQueue;
 
     private RetryOptions retryOptions;
 
@@ -72,7 +72,7 @@ private Builder(ActivityOptions options) {
       if (options == null) {
         return;
       }
-      this.taskList = options.taskList;
+      this.taskQueue = options.taskQueue;
       this.heartbeatTimeout = options.heartbeatTimeout;
       this.retryOptions = options.retryOptions;
       this.contextPropagators = options.contextPropagators;
@@ -84,7 +84,7 @@ private Builder(ActivityOptions options) {
 
     /**
      * Overall timeout workflow is willing to wait for activity to complete. It includes time in a
-     * task list (use {@link #setScheduleToStartTimeout(Duration)} to limit it) plus activity
+     * task queue (use {@link #setScheduleToStartTimeout(Duration)} to limit it) plus activity
      * execution time (use {@link #setStartToCloseTimeout(Duration)} to limit it). Either this
      * option or both schedule to start and start to close are required.
      */
@@ -94,7 +94,7 @@ public Builder setScheduleToCloseTimeout(Duration scheduleToCloseTimeout) {
     }
 
     /**
-     * Time activity can stay in task list before it is picked up by a worker. If schedule to close
+     * Time activity can stay in task queue before it is picked up by a worker. If schedule to close
      * is not provided then both this and start to close are required.
      */
     public Builder setScheduleToStartTimeout(Duration scheduleToStartTimeout) {
@@ -121,11 +121,11 @@ public Builder setHeartbeatTimeout(Duration heartbeatTimeoutSeconds) {
     }
 
     /**
-     * Task list to use when dispatching activity task to a worker. By default it is the same task
+     * Task queue to use when dispatching activity task to a worker. By default it is the same task
      * list name the workflow was started with.
      */
-    public Builder setTaskList(String taskList) {
-      this.taskList = taskList;
+    public Builder setTaskQueue(String taskQueue) {
+      this.taskQueue = taskQueue;
       return this;
     }
 
@@ -169,7 +169,7 @@ public ActivityOptions build() {
           scheduleToCloseTimeout,
           scheduleToStartTimeout,
           startToCloseTimeout,
-          taskList,
+          taskQueue,
           retryOptions,
           contextPropagators,
           cancellationType);
@@ -181,7 +181,7 @@ public ActivityOptions validateAndBuildWithDefaults() {
           scheduleToCloseTimeout,
           scheduleToStartTimeout,
           startToCloseTimeout,
-          taskList,
+          taskQueue,
           RetryOptions.newBuilder(retryOptions).validateBuildWithDefaults(),
           contextPropagators,
           cancellationType);
@@ -196,7 +196,7 @@ public ActivityOptions validateAndBuildWithDefaults() {
 
   private final Duration startToCloseTimeout;
 
-  private final String taskList;
+  private final String taskQueue;
 
   private final RetryOptions retryOptions;
 
@@ -209,7 +209,7 @@ private ActivityOptions(
       Duration scheduleToCloseTimeout,
       Duration scheduleToStartTimeout,
       Duration startToCloseTimeout,
-      String taskList,
+      String taskQueue,
       RetryOptions retryOptions,
       List<ContextPropagator> contextPropagators,
       ActivityCancellationType cancellationType) {
@@ -230,7 +230,7 @@ private ActivityOptions(
       this.scheduleToStartTimeout = scheduleToStartTimeout;
       this.startToCloseTimeout = startToCloseTimeout;
     }
-    this.taskList = taskList;
+    this.taskQueue = taskQueue;
     this.retryOptions = retryOptions;
     this.contextPropagators = contextPropagators;
     this.cancellationType = cancellationType;
@@ -252,8 +252,8 @@ public Duration getStartToCloseTimeout() {
     return startToCloseTimeout;
   }
 
-  public String getTaskList() {
-    return taskList;
+  public String getTaskQueue() {
+    return taskQueue;
   }
 
   public RetryOptions getRetryOptions() {
@@ -282,7 +282,7 @@ public boolean equals(Object o) {
         && Objects.equal(scheduleToCloseTimeout, that.scheduleToCloseTimeout)
         && Objects.equal(scheduleToStartTimeout, that.scheduleToStartTimeout)
         && Objects.equal(startToCloseTimeout, that.startToCloseTimeout)
-        && Objects.equal(taskList, that.taskList)
+        && Objects.equal(taskQueue, that.taskQueue)
         && Objects.equal(retryOptions, that.retryOptions)
         && Objects.equal(contextPropagators, that.contextPropagators);
   }
@@ -294,7 +294,7 @@ public int hashCode() {
         scheduleToCloseTimeout,
         scheduleToStartTimeout,
         startToCloseTimeout,
-        taskList,
+        taskQueue,
         retryOptions,
         contextPropagators,
         cancellationType);
@@ -311,8 +311,8 @@ public String toString() {
         + scheduleToStartTimeout
         + ", startToCloseTimeout="
         + startToCloseTimeout
-        + ", taskList='"
-        + taskList
+        + ", taskQueue='"
+        + taskQueue
         + '\''
         + ", retryOptions="
         + retryOptions

src/main/java/io/temporal/client/WorkflowOptions.java

@@ -62,7 +62,7 @@ public static WorkflowOptions merge(
         .setWorkflowTaskTimeout(o.getWorkflowTaskTimeout())
         .setWorkflowRunTimeout(o.getWorkflowRunTimeout())
         .setWorkflowExecutionTimeout(o.getWorkflowExecutionTimeout())
-        .setTaskList(o.getTaskList())
+        .setTaskQueue(o.getTaskQueue())
         .setRetryOptions(RetryOptions.merge(methodRetry, o.getRetryOptions()))
         .setCronSchedule(OptionsUtils.merge(cronAnnotation, o.getCronSchedule(), String.class))
         .setMemo(o.getMemo())
@@ -83,7 +83,7 @@ public static final class Builder {
 
     private Duration workflowTaskTimeout;
 
-    private String taskList;
+    private String taskQueue;
 
     private RetryOptions retryOptions;
 
@@ -106,7 +106,7 @@ private Builder(WorkflowOptions options) {
       this.workflowTaskTimeout = options.workflowTaskTimeout;
       this.workflowRunTimeout = options.workflowRunTimeout;
       this.workflowExecutionTimeout = options.workflowExecutionTimeout;
-      this.taskList = options.taskList;
+      this.taskQueue = options.taskQueue;
       this.retryOptions = options.retryOptions;
       this.cronSchedule = options.cronSchedule;
       this.memo = options.memo;
@@ -175,11 +175,11 @@ public Builder setWorkflowTaskTimeout(Duration workflowTaskTimeout) {
     }
 
     /**
-     * Task list to use for decision tasks. It should match a task list specified when creating a
+     * Task queue to use for decision tasks. It should match a task queue specified when creating a
      * {@link io.temporal.worker.Worker} that hosts the workflow code.
      */
-    public Builder setTaskList(String taskList) {
-      this.taskList = taskList;
+    public Builder setTaskQueue(String taskQueue) {
+      this.taskQueue = taskQueue;
       return this;
     }
 
@@ -224,7 +224,7 @@ public WorkflowOptions build() {
           workflowRunTimeout,
           workflowExecutionTimeout,
           workflowTaskTimeout,
-          taskList,
+          taskQueue,
           retryOptions,
           cronSchedule,
           memo,
@@ -242,7 +242,7 @@ public WorkflowOptions validateBuildWithDefaults() {
           workflowRunTimeout,
           workflowExecutionTimeout,
           workflowTaskTimeout,
-          taskList,
+          taskQueue,
           retryOptions,
           cronSchedule,
           memo,
@@ -261,7 +261,7 @@ public WorkflowOptions validateBuildWithDefaults() {
 
   private final Duration workflowTaskTimeout;
 
-  private final String taskList;
+  private final String taskQueue;
 
   private RetryOptions retryOptions;
 
@@ -279,7 +279,7 @@ private WorkflowOptions(
       Duration workflowRunTimeout,
       Duration workflowExecutionTimeout,
       Duration workflowTaskTimeout,
-      String taskList,
+      String taskQueue,
       RetryOptions retryOptions,
       String cronSchedule,
       Map<String, Object> memo,
@@ -290,7 +290,7 @@ private WorkflowOptions(
     this.workflowRunTimeout = workflowRunTimeout;
     this.workflowExecutionTimeout = workflowExecutionTimeout;
     this.workflowTaskTimeout = workflowTaskTimeout;
-    this.taskList = taskList;
+    this.taskQueue = taskQueue;
     this.retryOptions = retryOptions;
     this.cronSchedule = cronSchedule;
     this.memo = memo;
@@ -318,8 +318,8 @@ public Duration getWorkflowTaskTimeout() {
     return workflowTaskTimeout;
   }
 
-  public String getTaskList() {
-    return taskList;
+  public String getTaskQueue() {
+    return taskQueue;
   }
 
   public RetryOptions getRetryOptions() {
@@ -356,7 +356,7 @@ public boolean equals(Object o) {
         && Objects.equal(workflowRunTimeout, that.workflowRunTimeout)
         && Objects.equal(workflowExecutionTimeout, that.workflowExecutionTimeout)
         && Objects.equal(workflowTaskTimeout, that.workflowTaskTimeout)
-        && Objects.equal(taskList, that.taskList)
+        && Objects.equal(taskQueue, that.taskQueue)
         && Objects.equal(retryOptions, that.retryOptions)
         && Objects.equal(cronSchedule, that.cronSchedule)
         && Objects.equal(memo, that.memo)
@@ -372,7 +372,7 @@ public int hashCode() {
         workflowRunTimeout,
         workflowExecutionTimeout,
         workflowTaskTimeout,
-        taskList,
+        taskQueue,
         retryOptions,
         cronSchedule,
         memo,
@@ -394,8 +394,8 @@ public String toString() {
         + workflowExecutionTimeout
         + ", workflowTaskTimeout="
         + workflowTaskTimeout
-        + ", taskList='"
-        + taskList
+        + ", taskQueue='"
+        + taskQueue
         + '\''
         + ", retryOptions="
         + retryOptions

src/main/java/io/temporal/internal/common/InternalUtils.java

@@ -23,9 +23,9 @@
 import io.temporal.common.converter.DataConverter;
 import io.temporal.common.v1.Payload;
 import io.temporal.common.v1.SearchAttributes;
-import io.temporal.enums.v1.TaskListKind;
+import io.temporal.enums.v1.TaskQueueKind;
 import io.temporal.internal.worker.Shutdownable;
-import io.temporal.tasklist.v1.TaskList;
+import io.temporal.taskqueue.v1.TaskQueue;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.ExecutorService;
@@ -34,17 +34,17 @@
 /** Utility functions shared by the implementation code. */
 public final class InternalUtils {
 
-  public static TaskList createStickyTaskList(String taskListName) {
-    return TaskList.newBuilder()
-        .setName(taskListName)
-        .setKind(TaskListKind.TASK_LIST_KIND_STICKY)
+  public static TaskQueue createStickyTaskQueue(String taskQueueName) {
+    return TaskQueue.newBuilder()
+        .setName(taskQueueName)
+        .setKind(TaskQueueKind.TASK_QUEUE_KIND_STICKY)
         .build();
   }
 
-  public static TaskList createNormalTaskList(String taskListName) {
-    return TaskList.newBuilder()
-        .setName(taskListName)
-        .setKind(TaskListKind.TASK_LIST_KIND_NORMAL)
+  public static TaskQueue createNormalTaskQueue(String taskQueueName) {
+    return TaskQueue.newBuilder()
+        .setName(taskQueueName)
+        .setKind(TaskQueueKind.TASK_QUEUE_KIND_NORMAL)
         .build();
   }
 

src/main/java/io/temporal/internal/common/StartWorkflowExecutionParameters.java

@@ -39,7 +39,7 @@ public final class StartWorkflowExecutionParameters {
 
   private WorkflowType workflowType;
 
-  private String taskList;
+  private String taskQueue;
 
   private Optional<Payloads> input;
 
@@ -147,33 +147,33 @@ public StartWorkflowExecutionParameters withWorkflowIdReusePolicy(
   }
 
   /**
-   * Returns the value of the TaskList property for this object.
+   * Returns the value of the TaskQueue property for this object.
    *
-   * @return The value of the TaskList property for this object.
+   * @return The value of the TaskQueue property for this object.
    */
-  public String getTaskList() {
-    return taskList;
+  public String getTaskQueue() {
+    return taskQueue;
   }
 
   /**
-   * Sets the value of the TaskList property for this object.
+   * Sets the value of the TaskQueue property for this object.
    *
-   * @param taskList The new value for the TaskList property for this object.
+   * @param taskQueue The new value for the TaskQueue property for this object.
    */
-  public void setTaskList(String taskList) {
-    this.taskList = taskList;
+  public void setTaskQueue(String taskQueue) {
+    this.taskQueue = taskQueue;
   }
 
   /**
-   * Sets the value of the TaskList property for this object.
+   * Sets the value of the TaskQueue property for this object.
    *
    * <p>Returns a reference to this object so that method calls can be chained together.
    *
-   * @param taskList The new value for the TaskList property for this object.
+   * @param taskQueue The new value for the TaskQueue property for this object.
    * @return A reference to this updated object so that method calls can be chained together.
    */
-  public StartWorkflowExecutionParameters withTaskList(String taskList) {
-    this.taskList = taskList;
+  public StartWorkflowExecutionParameters withTaskQueue(String taskQueue) {
+    this.taskQueue = taskQueue;
     return this;
   }
 
@@ -339,7 +339,7 @@ public static StartWorkflowExecutionParameters fromWorkflowOptions(WorkflowOptio
     parameters.setWorkflowExecutionTimeoutSeconds(
         roundUpToSeconds(options.getWorkflowExecutionTimeout()));
     parameters.setWorkflowTaskTimeoutSeconds(roundUpToSeconds(options.getWorkflowTaskTimeout()));
-    parameters.setTaskList(options.getTaskList());
+    parameters.setTaskQueue(options.getTaskQueue());
     parameters.setWorkflowIdReusePolicy(options.getWorkflowIdReusePolicy());
     RetryOptions retryOptions = options.getRetryOptions();
     if (retryOptions != null) {
@@ -374,8 +374,8 @@ public String toString() {
         + '\''
         + ", workflowType="
         + workflowType
-        + ", taskList='"
-        + taskList
+        + ", taskQueue='"
+        + taskQueue
         + '\''
         + ", input="
         + input
@@ -410,7 +410,7 @@ public boolean equals(Object o) {
         && workflowTaskTimeoutSeconds == that.workflowTaskTimeoutSeconds
         && Objects.equal(workflowId, that.workflowId)
         && Objects.equal(workflowType, that.workflowType)
-        && Objects.equal(taskList, that.taskList)
+        && Objects.equal(taskQueue, that.taskQueue)
         && Objects.equal(input, that.input)
         && workflowIdReusePolicy == that.workflowIdReusePolicy
         && Objects.equal(retryParameters, that.retryParameters)
@@ -425,7 +425,7 @@ public int hashCode() {
     return Objects.hashCode(
         workflowId,
         workflowType,
-        taskList,
+        taskQueue,
         input,
         workflowRunTimeoutSeconds,
         workflowTaskTimeoutSeconds,