Skip to content

Commit a404bd2

Browse files
alexshtinalexshtin
authored
Rename task list to task queue (#62)
1 parent 82cef31 commit a404bd2

File tree

8 files changed

+69
-69
lines changed

8 files changed

+69
-69
lines changed

Diff for: ‎temporal/decision/v1/message.proto

+4-4
Original file line numberDiff line numberDiff line change
@@ -33,13 +33,13 @@ import "temporal/enums/v1/workflow.proto";
3333
import "temporal/enums/v1/decision_type.proto";
3434
import "temporal/common/v1/message.proto";
3535
import "temporal/failure/v1/message.proto";
36-
import "temporal/tasklist/v1/message.proto";
36+
import "temporal/taskqueue/v1/message.proto";
3737

3838
message ScheduleActivityTaskDecisionAttributes {
3939
string activity_id = 1;
4040
temporal.common.v1.ActivityType activity_type = 2;
4141
string namespace = 3;
42-
temporal.tasklist.v1.TaskList task_list = 4;
42+
temporal.taskqueue.v1.TaskQueue task_queue = 4;
4343
temporal.common.v1.Header header = 5;
4444
temporal.common.v1.Payloads input = 6;
4545
// Indicates how long the caller is willing to wait for an activity completion.
@@ -116,7 +116,7 @@ message RecordMarkerDecisionAttributes {
116116

117117
message ContinueAsNewWorkflowExecutionDecisionAttributes {
118118
temporal.common.v1.WorkflowType workflow_type = 1;
119-
temporal.tasklist.v1.TaskList task_list = 2;
119+
temporal.taskqueue.v1.TaskQueue task_queue = 2;
120120
temporal.common.v1.Payloads input = 3;
121121
// workflowExecutionTimeout is omitted as it shouldn'be overridden from within a workflow
122122
// Timeout of a single workflow run
@@ -138,7 +138,7 @@ message StartChildWorkflowExecutionDecisionAttributes {
138138
string namespace = 1;
139139
string workflow_id = 2;
140140
temporal.common.v1.WorkflowType workflow_type = 3;
141-
temporal.tasklist.v1.TaskList task_list = 4;
141+
temporal.taskqueue.v1.TaskQueue task_queue = 4;
142142
temporal.common.v1.Payloads input = 5;
143143
// Total workflow execution timeout including retries and continue as new
144144
int32 workflow_execution_timeout_seconds = 6;

Diff for: ‎temporal/enums/v1/failed_cause.proto

+1-1
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ enum DecisionTaskFailedCause {
4343
DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES = 10;
4444
DECISION_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES = 11;
4545
DECISION_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID = 12;
46-
DECISION_TASK_FAILED_CAUSE_RESET_STICKY_TASKLIST = 13;
46+
DECISION_TASK_FAILED_CAUSE_RESET_STICKY_TASK_QUEUE = 13;
4747
DECISION_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE = 14;
4848
DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES = 15;
4949
DECISION_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES = 16;

Diff for: ‎temporal/enums/v1/task_list.proto renamed to ‎temporal/enums/v1/task_queue.proto

+11-11
Original file line numberDiff line numberDiff line change
@@ -27,18 +27,18 @@ package temporal.enums.v1;
2727
option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
2828
option java_package = "io.temporal.enums.v1";
2929
option java_multiple_files = true;
30-
option java_outer_classname = "TaskListProto";
30+
option java_outer_classname = "TaskQueueProto";
3131

32-
enum TaskListKind {
33-
TASK_LIST_KIND_UNSPECIFIED = 0;
34-
TASK_LIST_KIND_NORMAL = 1;
35-
TASK_LIST_KIND_STICKY = 2;
32+
enum TaskQueueKind {
33+
TASK_QUEUE_KIND_UNSPECIFIED = 0;
34+
TASK_QUEUE_KIND_NORMAL = 1;
35+
TASK_QUEUE_KIND_STICKY = 2;
3636
}
3737

38-
enum TaskListType {
39-
TASK_LIST_TYPE_UNSPECIFIED = 0;
40-
// Decision type of task list.
41-
TASK_LIST_TYPE_DECISION = 1;
42-
// Activity type of task list.
43-
TASK_LIST_TYPE_ACTIVITY = 2;
38+
enum TaskQueueType {
39+
TASK_QUEUE_TYPE_UNSPECIFIED = 0;
40+
// Decision type of task queue.
41+
TASK_QUEUE_TYPE_DECISION = 1;
42+
// Activity type of task queue.
43+
TASK_QUEUE_TYPE_ACTIVITY = 2;
4444
}

Diff for: ‎temporal/history/v1/message.proto

+6-6
Original file line numberDiff line numberDiff line change
@@ -35,14 +35,14 @@ import "temporal/enums/v1/workflow.proto";
3535
import "temporal/common/v1/message.proto";
3636
import "temporal/failure/v1/message.proto";
3737
import "temporal/workflow/v1/message.proto";
38-
import "temporal/tasklist/v1/message.proto";
38+
import "temporal/taskqueue/v1/message.proto";
3939

4040
message WorkflowExecutionStartedEventAttributes {
4141
temporal.common.v1.WorkflowType workflow_type = 1;
4242
string parent_workflow_namespace = 2;
4343
temporal.common.v1.WorkflowExecution parent_workflow_execution = 3;
4444
int64 parent_initiated_event_id = 4;
45-
temporal.tasklist.v1.TaskList task_list = 5;
45+
temporal.taskqueue.v1.TaskQueue task_queue = 5;
4646
temporal.common.v1.Payloads input = 6;
4747
// Total workflow execution timeout including retries and continue as new.
4848
int32 workflow_execution_timeout_seconds = 7;
@@ -90,7 +90,7 @@ message WorkflowExecutionTimedOutEventAttributes {
9090
message WorkflowExecutionContinuedAsNewEventAttributes {
9191
string new_execution_run_id = 1;
9292
temporal.common.v1.WorkflowType workflow_type = 2;
93-
temporal.tasklist.v1.TaskList task_list = 3;
93+
temporal.taskqueue.v1.TaskQueue task_queue = 3;
9494
temporal.common.v1.Payloads input = 4;
9595
// workflow_execution_timeout is omitted as it shouldn'be overridden from within a workflow.
9696
// Timeout of a single workflow run.
@@ -108,7 +108,7 @@ message WorkflowExecutionContinuedAsNewEventAttributes {
108108
}
109109

110110
message DecisionTaskScheduledEventAttributes {
111-
temporal.tasklist.v1.TaskList task_list = 1;
111+
temporal.taskqueue.v1.TaskQueue task_queue = 1;
112112
int32 start_to_close_timeout_seconds = 2;
113113
int64 attempt = 3;
114114
}
@@ -149,7 +149,7 @@ message ActivityTaskScheduledEventAttributes {
149149
string activity_id = 1;
150150
temporal.common.v1.ActivityType activity_type = 2;
151151
string namespace = 3;
152-
temporal.tasklist.v1.TaskList task_list = 4;
152+
temporal.taskqueue.v1.TaskQueue task_queue = 4;
153153
temporal.common.v1.Header header = 5;
154154
temporal.common.v1.Payloads input = 6;
155155
// Indicates how long the caller is willing to wait for an activity completion.
@@ -330,7 +330,7 @@ message StartChildWorkflowExecutionInitiatedEventAttributes {
330330
string namespace = 1;
331331
string workflow_id = 2;
332332
temporal.common.v1.WorkflowType workflow_type = 3;
333-
temporal.tasklist.v1.TaskList task_list = 4;
333+
temporal.taskqueue.v1.TaskQueue task_queue = 4;
334334
temporal.common.v1.Payloads input = 5;
335335
// Total workflow execution timeout including retries and continue as new.
336336
int32 workflow_execution_timeout_seconds = 6;

Diff for: ‎temporal/tasklist/v1/message.proto renamed to ‎temporal/taskqueue/v1/message.proto

+10-10
Original file line numberDiff line numberDiff line change
@@ -22,26 +22,26 @@
2222

2323
syntax = "proto3";
2424

25-
package temporal.tasklist.v1;
25+
package temporal.taskqueue.v1;
2626

27-
option go_package = "go.temporal.io/temporal-proto/tasklist/v1;tasklist";
28-
option java_package = "io.temporal.tasklist.v1";
27+
option go_package = "go.temporal.io/temporal-proto/taskqueue/v1;taskqueue";
28+
option java_package = "io.temporal.taskqueue.v1";
2929
option java_multiple_files = true;
3030
option java_outer_classname = "MessageProto";
3131

32-
import "temporal/enums/v1/task_list.proto";
32+
import "temporal/enums/v1/task_queue.proto";
3333
import "google/protobuf/wrappers.proto";
3434

35-
message TaskList {
35+
message TaskQueue {
3636
string name = 1;
37-
temporal.enums.v1.TaskListKind kind = 2;
37+
temporal.enums.v1.TaskQueueKind kind = 2;
3838
}
3939

40-
message TaskListMetadata {
40+
message TaskQueueMetadata {
4141
google.protobuf.DoubleValue max_tasks_per_second = 1;
4242
}
4343

44-
message TaskListStatus {
44+
message TaskQueueStatus {
4545
int64 backlog_count_hint = 1;
4646
int64 read_level = 2;
4747
int64 ack_level = 3;
@@ -54,7 +54,7 @@ message TaskIdBlock {
5454
int64 end_id = 2;
5555
}
5656

57-
message TaskListPartitionMetadata {
57+
message TaskQueuePartitionMetadata {
5858
string key = 1;
5959
string owner_host_name = 2;
6060
}
@@ -67,6 +67,6 @@ message PollerInfo {
6767
}
6868

6969
message StickyExecutionAttributes {
70-
TaskList worker_task_list = 1;
70+
TaskQueue worker_task_queue = 1;
7171
int32 schedule_to_start_timeout_seconds = 2;
7272
}

Diff for: ‎temporal/workflow/v1/message.proto

+3-3
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ option java_outer_classname = "MessageProto";
3232
import "temporal/enums/v1/workflow.proto";
3333
import "temporal/common/v1/message.proto";
3434
import "temporal/failure/v1/message.proto";
35-
import "temporal/tasklist/v1/message.proto";
35+
import "temporal/taskqueue/v1/message.proto";
3636
import "google/protobuf/wrappers.proto";
3737

3838
message WorkflowExecutionInfo {
@@ -48,11 +48,11 @@ message WorkflowExecutionInfo {
4848
temporal.common.v1.Memo memo = 10;
4949
temporal.common.v1.SearchAttributes search_attributes = 11;
5050
ResetPoints auto_reset_points = 12;
51-
string task_list = 13;
51+
string task_queue = 13;
5252
}
5353

5454
message WorkflowExecutionConfig {
55-
temporal.tasklist.v1.TaskList task_list = 1;
55+
temporal.taskqueue.v1.TaskQueue task_queue = 1;
5656
int32 workflow_execution_timeout_seconds = 2;
5757
int32 workflow_run_timeout_seconds = 3;
5858
int32 workflow_task_timeout_seconds = 4;

Diff for: ‎temporal/workflowservice/v1/request_response.proto

+23-23
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ import "temporal/enums/v1/namespace.proto";
3434
import "temporal/enums/v1/failed_cause.proto";
3535
import "temporal/enums/v1/common.proto";
3636
import "temporal/enums/v1/query.proto";
37-
import "temporal/enums/v1/task_list.proto";
37+
import "temporal/enums/v1/task_queue.proto";
3838
import "temporal/common/v1/message.proto";
3939
import "temporal/history/v1/message.proto";
4040
import "temporal/workflow/v1/message.proto";
@@ -44,7 +44,7 @@ import "temporal/filter/v1/message.proto";
4444
import "temporal/namespace/v1/message.proto";
4545
import "temporal/query/v1/message.proto";
4646
import "temporal/replication/v1/message.proto";
47-
import "temporal/tasklist/v1/message.proto";
47+
import "temporal/taskqueue/v1/message.proto";
4848
import "temporal/version/v1/message.proto";
4949

5050
message RegisterNamespaceRequest {
@@ -120,7 +120,7 @@ message StartWorkflowExecutionRequest {
120120
string namespace = 1;
121121
string workflow_id = 2;
122122
temporal.common.v1.WorkflowType workflow_type = 3;
123-
temporal.tasklist.v1.TaskList task_list = 4;
123+
temporal.taskqueue.v1.TaskQueue task_queue = 4;
124124
temporal.common.v1.Payloads input = 5;
125125
// Total workflow execution timeout including retries and continue as new.
126126
int32 workflow_execution_timeout_seconds = 6;
@@ -162,7 +162,7 @@ message GetWorkflowExecutionHistoryResponse {
162162

163163
message PollForDecisionTaskRequest {
164164
string namespace = 1;
165-
temporal.tasklist.v1.TaskList task_list = 2;
165+
temporal.taskqueue.v1.TaskQueue task_queue = 2;
166166
string identity = 3;
167167
string binary_checksum = 4;
168168
}
@@ -178,7 +178,7 @@ message PollForDecisionTaskResponse {
178178
temporal.history.v1.History history = 8;
179179
bytes next_page_token = 9;
180180
temporal.query.v1.WorkflowQuery query = 10;
181-
temporal.tasklist.v1.TaskList workflow_execution_task_list = 11;
181+
temporal.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11;
182182
int64 scheduled_timestamp = 12;
183183
int64 started_timestamp = 13;
184184
map<string, temporal.query.v1.WorkflowQuery> queries = 14;
@@ -188,7 +188,7 @@ message RespondDecisionTaskCompletedRequest {
188188
bytes task_token = 1;
189189
repeated temporal.decision.v1.Decision decisions = 2;
190190
string identity = 3;
191-
temporal.tasklist.v1.StickyExecutionAttributes sticky_attributes = 4;
191+
temporal.taskqueue.v1.StickyExecutionAttributes sticky_attributes = 4;
192192
bool return_new_decision_task = 5;
193193
bool force_create_new_decision_task = 6;
194194
string binary_checksum = 7;
@@ -212,9 +212,9 @@ message RespondDecisionTaskFailedResponse {
212212

213213
message PollForActivityTaskRequest {
214214
string namespace = 1;
215-
temporal.tasklist.v1.TaskList task_list = 2;
215+
temporal.taskqueue.v1.TaskQueue task_queue = 2;
216216
string identity = 3;
217-
temporal.tasklist.v1.TaskListMetadata task_list_metadata = 4;
217+
temporal.taskqueue.v1.TaskQueueMetadata task_queue_metadata = 4;
218218
}
219219

220220
message PollForActivityTaskResponse {
@@ -354,7 +354,7 @@ message SignalWithStartWorkflowExecutionRequest {
354354
string namespace = 1;
355355
string workflow_id = 2;
356356
temporal.common.v1.WorkflowType workflow_type = 3;
357-
temporal.tasklist.v1.TaskList task_list = 4;
357+
temporal.taskqueue.v1.TaskQueue task_queue = 4;
358358
temporal.common.v1.Payloads input = 5;
359359
// Total workflow execution timeout including retries and continue as new
360360
int32 workflow_execution_timeout_seconds = 6;
@@ -499,12 +499,12 @@ message RespondQueryTaskCompletedRequest {
499499
message RespondQueryTaskCompletedResponse {
500500
}
501501

502-
message ResetStickyTaskListRequest {
502+
message ResetStickyTaskQueueRequest {
503503
string namespace = 1;
504504
temporal.common.v1.WorkflowExecution execution = 2;
505505
}
506506

507-
message ResetStickyTaskListResponse {
507+
message ResetStickyTaskQueueResponse {
508508
}
509509

510510
message QueryWorkflowRequest {
@@ -532,16 +532,16 @@ message DescribeWorkflowExecutionResponse {
532532
repeated temporal.workflow.v1.PendingChildExecutionInfo pending_children = 4;
533533
}
534534

535-
message DescribeTaskListRequest {
535+
message DescribeTaskQueueRequest {
536536
string namespace = 1;
537-
temporal.tasklist.v1.TaskList task_list = 2;
538-
temporal.enums.v1.TaskListType task_list_type = 3;
539-
bool include_task_list_status = 4;
537+
temporal.taskqueue.v1.TaskQueue task_queue = 2;
538+
temporal.enums.v1.TaskQueueType task_queue_type = 3;
539+
bool include_task_queue_status = 4;
540540
}
541541

542-
message DescribeTaskListResponse {
543-
repeated temporal.tasklist.v1.PollerInfo pollers = 1;
544-
temporal.tasklist.v1.TaskListStatus task_list_status = 2;
542+
message DescribeTaskQueueResponse {
543+
repeated temporal.taskqueue.v1.PollerInfo pollers = 1;
544+
temporal.taskqueue.v1.TaskQueueStatus task_queue_status = 2;
545545
}
546546

547547
message GetClusterInfoRequest {
@@ -552,12 +552,12 @@ message GetClusterInfoResponse {
552552
temporal.version.v1.SupportedSDKVersions supported_sdk_versions = 1;
553553
}
554554

555-
message ListTaskListPartitionsRequest {
555+
message ListTaskQueuePartitionsRequest {
556556
string namespace = 1;
557-
temporal.tasklist.v1.TaskList task_list = 2;
557+
temporal.taskqueue.v1.TaskQueue task_queue = 2;
558558
}
559559

560-
message ListTaskListPartitionsResponse {
561-
repeated temporal.tasklist.v1.TaskListPartitionMetadata activity_task_list_partitions = 1;
562-
repeated temporal.tasklist.v1.TaskListPartitionMetadata decision_task_list_partitions = 2;
560+
message ListTaskQueuePartitionsResponse {
561+
repeated temporal.taskqueue.v1.TaskQueuePartitionMetadata activity_task_queue_partitions = 1;
562+
repeated temporal.taskqueue.v1.TaskQueuePartitionMetadata decision_task_queue_partitions = 2;
563563
}

0 commit comments

Comments
 (0)