Populate Sticky TaskListKind in RespondTaskCompleted request

shijiesheng · shijiesheng · commit 6eec1045690c · 2024-09-19T14:37:39.000-07:00
diff --git a/internal/internal_task_pollers.go b/internal/internal_task_pollers.go
@@ -448,7 +448,7 @@ func (wtp *workflowTaskPoller) RespondTaskCompleted(completedRequest interface{}
 			case *s.RespondDecisionTaskCompletedRequest:
 				if request.StickyAttributes == nil && !wtp.disableStickyExecution {
 					request.StickyAttributes = &s.StickyExecutionAttributes{
-						WorkerTaskList:                &s.TaskList{Name: common.StringPtr(getWorkerTaskList(wtp.stickyUUID))},
+						WorkerTaskList:                &s.TaskList{Name: common.StringPtr(getWorkerTaskList(wtp.stickyUUID)), Kind: s.TaskListKindSticky.Ptr()},
 						ScheduleToStartTimeoutSeconds: common.Int32Ptr(common.Int32Ceil(wtp.StickyScheduleToStartTimeout.Seconds())),
 					}
 				} else {

Original file line number	Diff line number	Diff line change
`@@ -448,7 +448,7 @@ func (wtp *workflowTaskPoller) RespondTaskCompleted(completedRequest interface{}`
`448`	`448`	`case *s.RespondDecisionTaskCompletedRequest:`
`449`	`449`	`if request.StickyAttributes == nil && !wtp.disableStickyExecution {`
`450`	`450`	`request.StickyAttributes = &s.StickyExecutionAttributes{`
`451`		`- WorkerTaskList: &s.TaskList{Name: common.StringPtr(getWorkerTaskList(wtp.stickyUUID))},`
	`451`	`+ WorkerTaskList: &s.TaskList{Name: common.StringPtr(getWorkerTaskList(wtp.stickyUUID)), Kind: s.TaskListKindSticky.Ptr()},`
`452`	`452`	`ScheduleToStartTimeoutSeconds: common.Int32Ptr(common.Int32Ceil(wtp.StickyScheduleToStartTimeout.Seconds())),`
`453`	`453`	`}`
`454`	`454`	`} else {`