Skip to content

Commit 71b8a1a

Browse files
alexshtinalexshtin
authored
Set task queue kind explicitly (#545)
1 parent bfa0fce commit 71b8a1a

30 files changed

+223
-148
lines changed

‎service/frontend/errors.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,6 @@ var (
3131
errTaskTokenNotSet = serviceerror.NewInvalidArgument("Task token not set on request.")
3232
errInvalidTaskToken = serviceerror.NewInvalidArgument("Invalid TaskToken.")
3333
errTaskQueueNotSet = serviceerror.NewInvalidArgument("TaskQueue is not set on request.")
34-
errTaskQueueTypeNotSet = serviceerror.NewInvalidArgument("TaskQueueType is not set on request.")
3534
errExecutionNotSet = serviceerror.NewInvalidArgument("Execution is not set on request.")
3635
errWorkflowIDNotSet = serviceerror.NewInvalidArgument("WorkflowId is not set on request.")
3736
errActivityIDNotSet = serviceerror.NewInvalidArgument("ActivityId is not set on request.")

‎service/frontend/workflowHandler.go‎

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2870,8 +2870,11 @@ func (wh *WorkflowHandler) RespondQueryTaskCompleted(ctx context.Context, reques
28702870
FeatureVersion: headers[1],
28712871
}
28722872
matchingRequest := &matchingservice.RespondQueryTaskCompletedRequest{
2873-
NamespaceId: queryTaskToken.GetNamespaceId(),
2874-
TaskQueue: &taskqueuepb.TaskQueue{Name: queryTaskToken.GetTaskQueue()},
2873+
NamespaceId: queryTaskToken.GetNamespaceId(),
2874+
TaskQueue: &taskqueuepb.TaskQueue{
2875+
Name: queryTaskToken.GetTaskQueue(),
2876+
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
2877+
},
28752878
TaskId: queryTaskToken.GetTaskId(),
28762879
CompletedRequest: request,
28772880
}
@@ -3091,10 +3094,6 @@ func (wh *WorkflowHandler) DescribeTaskQueue(ctx context.Context, request *workf
30913094
return nil, err
30923095
}
30933096

3094-
if request.GetTaskQueueType() == enumspb.TASK_QUEUE_TYPE_UNSPECIFIED {
3095-
return nil, wh.error(errTaskQueueTypeNotSet, scope)
3096-
}
3097-
30983097
var matchingResponse *matchingservice.DescribeTaskQueueResponse
30993098
op := func() error {
31003099
var err error

‎service/history/commandChecker.go‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -620,7 +620,9 @@ func (v *commandAttrValidator) validatedTaskQueue(
620620
) (*taskqueuepb.TaskQueue, error) {
621621

622622
if taskQueue == nil {
623-
taskQueue = &taskqueuepb.TaskQueue{}
623+
taskQueue = &taskqueuepb.TaskQueue{
624+
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
625+
}
624626
}
625627

626628
if taskQueue.GetName() == "" {

‎service/history/commandChecker_test.go‎

Lines changed: 16 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -508,8 +508,11 @@ func (s *commandAttrValidatorSuite) TestValidateCrossNamespaceCall_GlobalToGloba
508508
}
509509

510510
func (s *commandAttrValidatorSuite) TestValidateTaskQueueName() {
511-
taskQueue := func(name string) *taskqueuepb.TaskQueue {
512-
return &taskqueuepb.TaskQueue{Name: name, Kind: enumspb.TASK_QUEUE_KIND_NORMAL}
511+
newTaskQueue := func(name string) *taskqueuepb.TaskQueue {
512+
return &taskqueuepb.TaskQueue{
513+
Name: name,
514+
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
515+
}
513516
}
514517

515518
testCases := []struct {
@@ -518,17 +521,17 @@ func (s *commandAttrValidatorSuite) TestValidateTaskQueueName() {
518521
output *taskqueuepb.TaskQueue
519522
isOutputErr bool
520523
}{
521-
{"tq-1", nil, &taskqueuepb.TaskQueue{Name: "tq-1"}, false},
522-
{"", taskQueue("tq-1"), taskQueue("tq-1"), false},
523-
{"tq-1", taskQueue("tq-1"), taskQueue("tq-1"), false},
524-
{"", taskQueue("/tl-1"), taskQueue("/tl-1"), false},
525-
{"", taskQueue("/__temporal_sys"), taskQueue("/__temporal_sys"), false},
526-
{"", nil, &taskqueuepb.TaskQueue{}, true},
527-
{"", taskQueue(""), taskQueue(""), true},
528-
{"", taskQueue(reservedTaskQueuePrefix), taskQueue(reservedTaskQueuePrefix), true},
529-
{"tq-1", taskQueue(reservedTaskQueuePrefix), taskQueue(reservedTaskQueuePrefix), true},
530-
{"", taskQueue(reservedTaskQueuePrefix + "tq-1"), taskQueue(reservedTaskQueuePrefix + "tq-1"), true},
531-
{"tq-1", taskQueue(reservedTaskQueuePrefix + "tq-1"), taskQueue(reservedTaskQueuePrefix + "tq-1"), true},
524+
{"tq-1", nil, newTaskQueue("tq-1"), false},
525+
{"", newTaskQueue("tq-1"), newTaskQueue("tq-1"), false},
526+
{"tq-1", newTaskQueue("tq-1"), newTaskQueue("tq-1"), false},
527+
{"", newTaskQueue("/tl-1"), newTaskQueue("/tl-1"), false},
528+
{"", newTaskQueue("/__temporal_sys"), newTaskQueue("/__temporal_sys"), false},
529+
{"", nil, newTaskQueue(""), true},
530+
{"", newTaskQueue(""), newTaskQueue(""), true},
531+
{"", newTaskQueue(reservedTaskQueuePrefix), newTaskQueue(reservedTaskQueuePrefix), true},
532+
{"tq-1", newTaskQueue(reservedTaskQueuePrefix), newTaskQueue(reservedTaskQueuePrefix), true},
533+
{"", newTaskQueue(reservedTaskQueuePrefix + "tq-1"), newTaskQueue(reservedTaskQueuePrefix + "tq-1"), true},
534+
{"tq-1", newTaskQueue(reservedTaskQueuePrefix + "tq-1"), newTaskQueue(reservedTaskQueuePrefix + "tq-1"), true},
532535
}
533536

534537
for _, tc := range testCases {

‎service/history/historyBuilder.go‎

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -87,14 +87,14 @@ func (b *historyBuilder) AddWorkflowExecutionStartedEvent(request *historyservic
8787
return b.addEventToHistory(event)
8888
}
8989

90-
func (b *historyBuilder) AddWorkflowTaskScheduledEvent(taskQueue string,
90+
func (b *historyBuilder) AddWorkflowTaskScheduledEvent(taskQueue *taskqueuepb.TaskQueue,
9191
startToCloseTimeoutSeconds int32, attempt int64) *historypb.HistoryEvent {
9292
event := b.newWorkflowTaskScheduledEvent(taskQueue, startToCloseTimeoutSeconds, attempt)
9393

9494
return b.addEventToHistory(event)
9595
}
9696

97-
func (b *historyBuilder) AddTransientWorkflowTaskScheduledEvent(taskQueue string,
97+
func (b *historyBuilder) AddTransientWorkflowTaskScheduledEvent(taskQueue *taskqueuepb.TaskQueue,
9898
startToCloseTimeoutSeconds int32, attempt int64, timestamp int64) *historypb.HistoryEvent {
9999
event := b.newTransientWorkflowTaskScheduledEvent(taskQueue, startToCloseTimeoutSeconds, attempt, timestamp)
100100

@@ -496,14 +496,14 @@ func (b *historyBuilder) newWorkflowExecutionStartedEvent(
496496
return historyEvent
497497
}
498498

499-
func (b *historyBuilder) newWorkflowTaskScheduledEvent(taskQueue string, startToCloseTimeoutSeconds int32,
499+
func (b *historyBuilder) newWorkflowTaskScheduledEvent(taskQueue *taskqueuepb.TaskQueue, startToCloseTimeoutSeconds int32,
500500
attempt int64) *historypb.HistoryEvent {
501501
historyEvent := b.msBuilder.CreateNewHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_TASK_SCHEDULED)
502502

503503
return setWorkflowTaskScheduledEventInfo(historyEvent, taskQueue, startToCloseTimeoutSeconds, attempt)
504504
}
505505

506-
func (b *historyBuilder) newTransientWorkflowTaskScheduledEvent(taskQueue string, startToCloseTimeoutSeconds int32,
506+
func (b *historyBuilder) newTransientWorkflowTaskScheduledEvent(taskQueue *taskqueuepb.TaskQueue, startToCloseTimeoutSeconds int32,
507507
attempt int64, timestamp int64) *historypb.HistoryEvent {
508508
historyEvent := b.msBuilder.CreateNewHistoryEventWithTimestamp(enumspb.EVENT_TYPE_WORKFLOW_TASK_SCHEDULED, timestamp)
509509

@@ -1008,7 +1008,7 @@ func (b *historyBuilder) newChildWorkflowExecutionTimedOutEvent(namespace string
10081008
return historyEvent
10091009
}
10101010

1011-
func newWorkflowTaskScheduledEventWithInfo(eventID, timestamp int64, taskQueue string, startToCloseTimeoutSeconds int32,
1011+
func newWorkflowTaskScheduledEventWithInfo(eventID, timestamp int64, taskQueue *taskqueuepb.TaskQueue, startToCloseTimeoutSeconds int32,
10121012
attempt int64) *historypb.HistoryEvent {
10131013
historyEvent := createNewHistoryEvent(eventID, enumspb.EVENT_TYPE_WORKFLOW_TASK_SCHEDULED, timestamp)
10141014

@@ -1031,11 +1031,10 @@ func createNewHistoryEvent(eventID int64, eventType enumspb.EventType, timestamp
10311031
return historyEvent
10321032
}
10331033

1034-
func setWorkflowTaskScheduledEventInfo(historyEvent *historypb.HistoryEvent, taskQueue string,
1034+
func setWorkflowTaskScheduledEventInfo(historyEvent *historypb.HistoryEvent, taskQueue *taskqueuepb.TaskQueue,
10351035
startToCloseTimeoutSeconds int32, attempt int64) *historypb.HistoryEvent {
10361036
attributes := &historypb.WorkflowTaskScheduledEventAttributes{}
1037-
attributes.TaskQueue = &taskqueuepb.TaskQueue{}
1038-
attributes.TaskQueue.Name = taskQueue
1037+
attributes.TaskQueue = taskQueue
10391038
attributes.StartToCloseTimeoutSeconds = startToCloseTimeoutSeconds
10401039
attributes.Attempt = attempt
10411040
historyEvent.Attributes = &historypb.HistoryEvent_WorkflowTaskScheduledEventAttributes{WorkflowTaskScheduledEventAttributes: attributes}

‎service/history/historyBuilder_test.go‎

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderDynamicSuccess() {
114114
id := "dynamic-historybuilder-success-test-workflow-id"
115115
rid := "dynamic-historybuilder-success-test-run-id"
116116
wt := "dynamic-historybuilder-success-type"
117-
tl := "dynamic-historybuilder-success-taskqueue"
117+
tl := &taskqueuepb.TaskQueue{Kind: enumspb.TASK_QUEUE_KIND_NORMAL, Name: "dynamic-historybuilder-success-taskqueue"}
118118
identity := "dynamic-historybuilder-success-worker"
119119
input := payloads.EncodeString("dynamic-historybuilder-success-input")
120120
execTimeout := int32(70)
@@ -318,7 +318,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderWorkflowStartFailures() {
318318
id := "historybuilder-workflowstart-failures-test-workflow-id"
319319
rid := "historybuilder-workflowstart-failures-test-run-id"
320320
wt := "historybuilder-workflowstart-failures-type"
321-
tl := "historybuilder-workflowstart-failures-taskqueue"
321+
tl := &taskqueuepb.TaskQueue{Kind: enumspb.TASK_QUEUE_KIND_NORMAL, Name: "historybuilder-workflowstart-failures-taskqueue"}
322322
identity := "historybuilder-workflowstart-failures-worker"
323323
input := payloads.EncodeString("historybuilder-workflowstart-failures-input")
324324
execTimeout := int32(70)
@@ -349,7 +349,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderWorkflowStartFailures() {
349349
StartRequest: &workflowservice.StartWorkflowExecutionRequest{
350350
WorkflowId: we.WorkflowId,
351351
WorkflowType: &commonpb.WorkflowType{Name: wt},
352-
TaskQueue: &taskqueuepb.TaskQueue{Name: tl},
352+
TaskQueue: tl,
353353
Input: input,
354354
WorkflowExecutionTimeoutSeconds: execTimeout,
355355
WorkflowRunTimeoutSeconds: runTimeout,
@@ -370,7 +370,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderWorkflowTaskScheduledFailures()
370370
id := "historybuilder-workflow-task-scheduled-failures-test-workflow-id"
371371
rid := "historybuilder-workflow-task-scheduled-failures-test-run-id"
372372
wt := "historybuilder-workflow-task-scheduled-failures-type"
373-
tl := "historybuilder-workflow-task-scheduled-failures-taskqueue"
373+
tl := &taskqueuepb.TaskQueue{Kind: enumspb.TASK_QUEUE_KIND_NORMAL, Name: "historybuilder-workflow-task-scheduled-failures-taskqueue"}
374374
identity := "historybuilder-workflow-task-scheduled-failures-worker"
375375
input := payloads.EncodeString("historybuilder-workflow-task-scheduled-failures-input")
376376
execTimeout := int32(70)
@@ -406,7 +406,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderWorkflowTaskStartedFailures() {
406406
id := "historybuilder-workflow-task-started-failures-test-workflow-id"
407407
rid := "historybuilder-workflow-task-started-failures-test-run-id"
408408
wt := "historybuilder-workflow-task-started-failures-type"
409-
tl := "historybuilder-workflow-task-started-failures-taskqueue"
409+
tl := &taskqueuepb.TaskQueue{Kind: enumspb.TASK_QUEUE_KIND_NORMAL, Name: "historybuilder-workflow-task-started-failures-taskqueue"}
410410
identity := "historybuilder-workflow-task-started-failures-worker"
411411
input := payloads.EncodeString("historybuilder-workflow-task-started-failures-input")
412412
execTimeout := int32(70)
@@ -422,7 +422,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderWorkflowTaskStartedFailures() {
422422
s.Equal(int64(2), s.getNextEventID())
423423

424424
_, _, err := s.msBuilder.AddWorkflowTaskStartedEvent(2, uuid.New(), &workflowservice.PollWorkflowTaskQueueRequest{
425-
TaskQueue: &taskqueuepb.TaskQueue{Name: tl},
425+
TaskQueue: tl,
426426
Identity: identity,
427427
})
428428
s.NotNil(err)
@@ -440,7 +440,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderWorkflowTaskStartedFailures() {
440440
s.Equal(common.EmptyEventID, s.getPreviousWorkflowTaskStartedEventID())
441441

442442
_, _, err = s.msBuilder.AddWorkflowTaskStartedEvent(100, uuid.New(), &workflowservice.PollWorkflowTaskQueueRequest{
443-
TaskQueue: &taskqueuepb.TaskQueue{Name: tl},
443+
TaskQueue: tl,
444444
Identity: identity,
445445
})
446446
s.NotNil(err)
@@ -463,7 +463,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderFlushBufferedEvents() {
463463
id := "flush-buffered-events-test-workflow-id"
464464
rid := "flush-buffered-events-test-run-id"
465465
wt := "flush-buffered-events-type"
466-
tl := "flush-buffered-events-taskqueue"
466+
tl := &taskqueuepb.TaskQueue{Kind: enumspb.TASK_QUEUE_KIND_NORMAL, Name: "flush-buffered-events-taskqueue"}
467467
identity := "flush-buffered-events-worker"
468468
input := payloads.EncodeString("flush-buffered-events-input")
469469
execTimeout := int32(70)
@@ -627,7 +627,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderFlushBufferedEvents() {
627627

628628
func (s *historyBuilderSuite) TestHistoryBuilderWorkflowCancellationRequested() {
629629
workflowType := "some random workflow type"
630-
taskqueue := "some random taskqueue"
630+
taskqueue := &taskqueuepb.TaskQueue{Kind: enumspb.TASK_QUEUE_KIND_NORMAL, Name: "some random taskqueue"}
631631
identity := "some random identity"
632632
input := payloads.EncodeString("some random workflow input")
633633
execTimeout := int32(70)
@@ -699,7 +699,7 @@ func (s *historyBuilderSuite) TestHistoryBuilderWorkflowCancellationRequested()
699699

700700
func (s *historyBuilderSuite) TestHistoryBuilderWorkflowCancellationFailed() {
701701
workflowType := "some random workflow type"
702-
taskqueue := "some random taskqueue"
702+
taskqueue := &taskqueuepb.TaskQueue{Kind: enumspb.TASK_QUEUE_KIND_NORMAL, Name: "some random taskqueue"}
703703
identity := "some random identity"
704704
input := payloads.EncodeString("some random workflow input")
705705
execTimeout := int32(70)
@@ -782,13 +782,13 @@ func (s *historyBuilderSuite) getPreviousWorkflowTaskStartedEventID() int64 {
782782
return s.msBuilder.GetExecutionInfo().LastProcessedEvent
783783
}
784784

785-
func (s *historyBuilderSuite) addWorkflowExecutionStartedEvent(we commonpb.WorkflowExecution, workflowType,
786-
taskQueue string, input *commonpb.Payloads, executionTimeout, runTimeout, taskTimeout int32, identity string) *historypb.HistoryEvent {
785+
func (s *historyBuilderSuite) addWorkflowExecutionStartedEvent(we commonpb.WorkflowExecution, workflowType string,
786+
taskQueue *taskqueuepb.TaskQueue, input *commonpb.Payloads, executionTimeout, runTimeout, taskTimeout int32, identity string) *historypb.HistoryEvent {
787787

788788
request := &workflowservice.StartWorkflowExecutionRequest{
789789
WorkflowId: we.WorkflowId,
790790
WorkflowType: &commonpb.WorkflowType{Name: workflowType},
791-
TaskQueue: &taskqueuepb.TaskQueue{Name: taskQueue},
791+
TaskQueue: taskQueue,
792792
Input: input,
793793
WorkflowExecutionTimeoutSeconds: executionTimeout,
794794
WorkflowRunTimeoutSeconds: runTimeout,
@@ -816,9 +816,9 @@ func (s *historyBuilderSuite) addWorkflowTaskScheduledEvent() *workflowTaskInfo
816816
}
817817

818818
func (s *historyBuilderSuite) addWorkflowTaskStartedEvent(scheduleID int64,
819-
taskQueue, identity string) *historypb.HistoryEvent {
819+
taskQueue *taskqueuepb.TaskQueue, identity string) *historypb.HistoryEvent {
820820
event, _, err := s.msBuilder.AddWorkflowTaskStartedEvent(scheduleID, uuid.New(), &workflowservice.PollWorkflowTaskQueueRequest{
821-
TaskQueue: &taskqueuepb.TaskQueue{Name: taskQueue},
821+
TaskQueue: taskQueue,
822822
Identity: identity,
823823
})
824824
s.Nil(err)
@@ -934,15 +934,15 @@ func (s *historyBuilderSuite) addRequestCancelExternalWorkflowExecutionFailedEve
934934
return event
935935
}
936936

937-
func (s *historyBuilderSuite) validateWorkflowExecutionStartedEvent(event *historypb.HistoryEvent, workflowType,
938-
taskQueue string, input *commonpb.Payloads, executionTimeout, runTimeout, taskTimeout int32, identity string) {
937+
func (s *historyBuilderSuite) validateWorkflowExecutionStartedEvent(event *historypb.HistoryEvent, workflowType string,
938+
taskQueue *taskqueuepb.TaskQueue, input *commonpb.Payloads, executionTimeout, runTimeout, taskTimeout int32, identity string) {
939939
s.NotNil(event)
940940
s.Equal(enumspb.EVENT_TYPE_WORKFLOW_EXECUTION_STARTED, event.EventType)
941941
s.Equal(common.FirstEventID, event.EventId)
942942
attributes := event.GetWorkflowExecutionStartedEventAttributes()
943943
s.NotNil(attributes)
944944
s.Equal(workflowType, attributes.WorkflowType.Name)
945-
s.Equal(taskQueue, attributes.TaskQueue.Name)
945+
s.Equal(taskQueue, attributes.TaskQueue)
946946
s.Equal(input, attributes.Input)
947947
s.Equal(executionTimeout, attributes.WorkflowExecutionTimeoutSeconds)
948948
s.Equal(runTimeout, attributes.WorkflowRunTimeoutSeconds)
@@ -951,7 +951,7 @@ func (s *historyBuilderSuite) validateWorkflowExecutionStartedEvent(event *histo
951951
}
952952

953953
func (s *historyBuilderSuite) validateWorkflowTaskScheduledEvent(di *workflowTaskInfo, eventID int64,
954-
taskQueue string, timeout int32) {
954+
taskQueue *taskqueuepb.TaskQueue, timeout int32) {
955955
s.NotNil(di)
956956
s.Equal(eventID, di.ScheduleID)
957957
s.Equal(taskQueue, di.TaskQueue)

‎service/history/historyEngine.go‎

Lines changed: 17 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1075,13 +1075,19 @@ func (e *historyEngineImpl) getMutableState(
10751075
execution.RunId = context.getExecution().RunId
10761076
workflowState, workflowStatus := mutableState.GetWorkflowStateStatus()
10771077
retResp = &historyservice.GetMutableStateResponse{
1078-
Execution: &execution,
1079-
WorkflowType: &commonpb.WorkflowType{Name: executionInfo.WorkflowTypeName},
1080-
LastFirstEventId: mutableState.GetLastFirstEventID(),
1081-
NextEventId: mutableState.GetNextEventID(),
1082-
PreviousStartedEventId: mutableState.GetPreviousStartedEventID(),
1083-
TaskQueue: &taskqueuepb.TaskQueue{Name: executionInfo.TaskQueue},
1084-
StickyTaskQueue: &taskqueuepb.TaskQueue{Name: executionInfo.StickyTaskQueue},
1078+
Execution: &execution,
1079+
WorkflowType: &commonpb.WorkflowType{Name: executionInfo.WorkflowTypeName},
1080+
LastFirstEventId: mutableState.GetLastFirstEventID(),
1081+
NextEventId: mutableState.GetNextEventID(),
1082+
PreviousStartedEventId: mutableState.GetPreviousStartedEventID(),
1083+
TaskQueue: &taskqueuepb.TaskQueue{
1084+
Name: executionInfo.TaskQueue,
1085+
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
1086+
},
1087+
StickyTaskQueue: &taskqueuepb.TaskQueue{
1088+
Name: executionInfo.StickyTaskQueue,
1089+
Kind: enumspb.TASK_QUEUE_KIND_STICKY,
1090+
},
10851091
ClientLibraryVersion: executionInfo.ClientLibraryVersion,
10861092
ClientFeatureVersion: executionInfo.ClientFeatureVersion,
10871093
ClientImpl: executionInfo.ClientImpl,
@@ -1222,7 +1228,10 @@ func (e *historyEngineImpl) DescribeWorkflowExecution(
12221228
executionInfo := mutableState.GetExecutionInfo()
12231229
result := &historyservice.DescribeWorkflowExecutionResponse{
12241230
ExecutionConfig: &workflowpb.WorkflowExecutionConfig{
1225-
TaskQueue: &taskqueuepb.TaskQueue{Name: executionInfo.TaskQueue},
1231+
TaskQueue: &taskqueuepb.TaskQueue{
1232+
Name: executionInfo.TaskQueue,
1233+
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
1234+
},
12261235
WorkflowExecutionTimeoutSeconds: executionInfo.WorkflowExecutionTimeout,
12271236
WorkflowRunTimeoutSeconds: executionInfo.WorkflowRunTimeout,
12281237
WorkflowTaskTimeoutSeconds: executionInfo.WorkflowTaskTimeout,

0 commit comments

Comments
 (0)