804
workflowTaskCompletedEventID int64,
805
command *commandpb.RecordMarkerCommandAttributes,
807
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_MARKER_RECORDED, b.timeSource.Now())
808
>
event.Attributes = &historypb.HistoryEvent_MarkerRecordedEventAttributes{
809
>
MarkerRecordedEventAttributes: &historypb.MarkerRecordedEventAttributes{
810
>
MarkerName: command.MarkerName,
811
>
Details: command.Details,
812
>
WorkflowTaskCompletedEventId: workflowTaskCompletedEventID,
813
>
Header: command.Header,
814
>
Failure: command.Failure,
815
>
},
816
>
}
817
>
return event
818
>
}
819
820
func (b *EventFactory) CreateWorkflowExecutionSignaledEvent(