337
command *commandpb.CompleteWorkflowExecutionCommandAttributes,
338
newExecutionRunID string,
340
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_EXECUTION_COMPLETED, b.timeSource.Now())
341
>
event.Attributes = &historypb.HistoryEvent_WorkflowExecutionCompletedEventAttributes{
342
>
WorkflowExecutionCompletedEventAttributes: &historypb.WorkflowExecutionCompletedEventAttributes{
343
>
WorkflowTaskCompletedEventId: workflowTaskCompletedEventID,
344
>
Result: command.Result,
345
>
NewExecutionRunId: newExecutionRunID,
346
>
},
347
>
}
348
>
return event
349
>
}
350
351
func (b *EventFactory) CreateFailWorkflowEvent(