expose workflowExecutionTasklist in PollForDecisionTaskResponse (cade…

…nce-workflow#1007) * expose workflowExecutionTasklist in PollForDecisionTaskResponse
siathalysedI · Jul 31, 2018 · 0b1e42a · 0b1e42a
1 parent bd79b91
commit 0b1e42a
Show file tree

Hide file tree

Showing 15 changed files with 336 additions and 59 deletions.
diff --git a/.gen/go/history/idl.go b/.gen/go/history/idl.go
diff --git a/.gen/go/history/types.go b/.gen/go/history/types.go
diff --git a/.gen/go/matching/idl.go b/.gen/go/matching/idl.go
diff --git a/.gen/go/matching/types.go b/.gen/go/matching/types.go
diff --git a/.gen/go/shared/idl.go b/.gen/go/shared/idl.go
diff --git a/.gen/go/shared/types.go b/.gen/go/shared/types.go
diff --git a/common/convert.go b/common/convert.go
@@ -99,6 +99,11 @@ func TaskListKindPtr(t s.TaskListKind) *s.TaskListKind {
 	return &t
 }
 
+// TaskListTypePtr makes a copy and returns the pointer to a TaskListKind.
+func TaskListTypePtr(t s.TaskListType) *s.TaskListType {
+	return &t
+}
+
 // DecisionTaskFailedCausePtr makes a copy and returns the pointer to a DecisionTaskFailedCause.
 func DecisionTaskFailedCausePtr(t s.DecisionTaskFailedCause) *s.DecisionTaskFailedCause {
 	return &t

diff --git a/common/util.go b/common/util.go
@@ -249,14 +249,15 @@ func GenerateRandomString(n int) string {
 // CreateMatchingPollForDecisionTaskResponse create response for matching's PollForDecisionTask
 func CreateMatchingPollForDecisionTaskResponse(historyResponse *h.RecordDecisionTaskStartedResponse, workflowExecution *workflow.WorkflowExecution, token []byte) *m.PollForDecisionTaskResponse {
 	matchingResp := &m.PollForDecisionTaskResponse{
-		WorkflowExecution:      workflowExecution,
-		TaskToken:              token,
-		Attempt:                Int64Ptr(historyResponse.GetAttempt()),
-		WorkflowType:           historyResponse.WorkflowType,
-		StartedEventId:         historyResponse.StartedEventId,
-		StickyExecutionEnabled: historyResponse.StickyExecutionEnabled,
-		NextEventId:            historyResponse.NextEventId,
-		DecisionInfo:           historyResponse.DecisionInfo,
+		WorkflowExecution:         workflowExecution,
+		TaskToken:                 token,
+		Attempt:                   Int64Ptr(historyResponse.GetAttempt()),
+		WorkflowType:              historyResponse.WorkflowType,
+		StartedEventId:            historyResponse.StartedEventId,
+		StickyExecutionEnabled:    historyResponse.StickyExecutionEnabled,
+		NextEventId:               historyResponse.NextEventId,
+		DecisionInfo:              historyResponse.DecisionInfo,
+		WorkflowExecutionTaskList: historyResponse.WorkflowExecutionTaskList,
 	}
 	if historyResponse.GetPreviousStartedEventId() != EmptyEventID {
 		matchingResp.PreviousStartedEventId = historyResponse.PreviousStartedEventId

diff --git a/idl/github.com/uber/cadence/history.thrift b/idl/github.com/uber/cadence/history.thrift
@@ -152,6 +152,7 @@ struct RecordDecisionTaskStartedResponse {
   60: optional i64 (js.type = "Long") attempt
   70: optional bool stickyExecutionEnabled
   80: optional shared.TransientDecisionInfo decisionInfo
+  90: optional shared.TaskList WorkflowExecutionTaskList
 }
 
 struct SignalWorkflowExecutionRequest {

diff --git a/idl/github.com/uber/cadence/matching.thrift b/idl/github.com/uber/cadence/matching.thrift
@@ -40,6 +40,7 @@ struct PollForDecisionTaskResponse {
   70: optional bool stickyExecutionEnabled
   80: optional shared.WorkflowQuery query
   90: optional shared.TransientDecisionInfo decisionInfo
+  100: optional shared.TaskList WorkflowExecutionTaskList
 }
 
 struct PollForActivityTaskRequest {

diff --git a/idl/github.com/uber/cadence/shared.thrift b/idl/github.com/uber/cadence/shared.thrift
@@ -881,6 +881,7 @@ struct PollForDecisionTaskResponse {
   60: optional History history
   70: optional binary nextPageToken
   80: optional WorkflowQuery query
+  90: optional TaskList WorkflowExecutionTaskList
 }
 
 struct StickyExecutionAttributes {