697
command *commandpb.SignalExternalWorkflowExecutionCommandAttributes,
698
targetNamespaceID namespace.ID,
700
>
event := b.createHistoryEvent(
701
>
enumspb.EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED,
702
>
b.timeSource.Now(),
703
>
)
704
>
event.Attributes = &historypb.HistoryEvent_SignalExternalWorkflowExecutionInitiatedEventAttributes{
705
>
SignalExternalWorkflowExecutionInitiatedEventAttributes: &historypb.SignalExternalWorkflowExecutionInitiatedEventAttributes{
706
>
WorkflowTaskCompletedEventId: workflowTaskCompletedEventID,
707
>
Namespace: command.Namespace,
708
>
NamespaceId: targetNamespaceID.String(),
709
>
WorkflowExecution: &commonpb.WorkflowExecution{
710
>
WorkflowId: command.Execution.WorkflowId,
711
>
RunId: command.Execution.RunId,
712
>
},
713
>
SignalName: command.SignalName,
714
>
Input: command.Input,
715
>
Control: command.Control,
716
>
ChildWorkflowOnly: command.ChildWorkflowOnly,
717
>
Header: command.Header,
718
>
},
719
>
}
720
>
return event
721
>
}
722
723
func (b *EventFactory) CreateUpsertWorkflowSearchAttributesEvent(