-
Notifications
You must be signed in to change notification settings - Fork 805
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add missing fields to WorkflowExecutionStartedEventAttributes #647
Add missing fields to WorkflowExecutionStartedEventAttributes #647
Conversation
20: optional TaskList taskList | ||
30: optional binary input | ||
40: optional i32 executionStartToCloseTimeoutSeconds | ||
50: optional i32 taskStartToCloseTimeoutSeconds | ||
52: optional ChildPolicy childPolicy |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
if the "child policy" represents what this workflow's parent want this workflow to do, then we should use a better name
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We are keeping our API as close to SWF as possible: https://docs.aws.amazon.com/amazonswf/latest/apireference/API_WorkflowExecutionStartedEventAttributes.html
@@ -812,6 +817,7 @@ struct StartWorkflowExecutionRequest { | |||
80: optional string identity | |||
90: optional string requestId | |||
100: optional WorkflowIdReusePolicy workflowIdReusePolicy | |||
110: optional ChildPolicy childPolicy |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
same here
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
same as above.
historyEvent := b.msBuilder.createNewHistoryEvent(workflow.EventTypeWorkflowExecutionStarted) | ||
attributes := &workflow.WorkflowExecutionStartedEventAttributes{} | ||
attributes.WorkflowType = request.WorkflowType | ||
attributes.TaskList = request.TaskList | ||
attributes.Input = request.Input | ||
attributes.ExecutionStartToCloseTimeoutSeconds = common.Int32Ptr(*request.ExecutionStartToCloseTimeoutSeconds) | ||
attributes.TaskStartToCloseTimeoutSeconds = common.Int32Ptr(*request.TaskStartToCloseTimeoutSeconds) | ||
attributes.ChildPolicy = request.ChildPolicy | ||
attributes.ContinuedExecutionRunId = previousRunID |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
previous run ID is better than ContinuedExecutionRunId, i assume
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same as above.
@@ -875,7 +875,7 @@ func (e *mutableStateBuilder) AddWorkflowExecutionStartedEventForContinueAsNew(d | |||
|
|||
createRequest := &workflow.StartWorkflowExecutionRequest{ | |||
RequestId: common.StringPtr(uuid.New()), | |||
Domain: common.StringPtr(previousExecutionState.executionInfo.DomainID), | |||
Domain: common.StringPtr(domainName), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this is a bug fix?
442d519
to
060d307
Compare
WorkflowExecutionStartedEventAttributes now also has support for parent execution info, child policy and continued execution run id. fixes cadence-workflow#425
060d307
to
3087dea
Compare
this is a complete rip off of aws swf, right? |
WorkflowExecutionStartedEventAttributes now also has support for parent
execution info, child policy and continued execution run id.
fixes #425