819
externalWorkflowSignaled := NewHistoryEventVertex(enumspb.EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_SIGNALED.String())
820
externalWorkflowSignaled.SetDataFunc(func(input ...any) any {
822
>
lastGeneratedEvent := input[1].(*historypb.HistoryEvent)
823
>
eventID := lastGeneratedEvent.GetEventId() + 1
824
>
version := input[2].(int64)
825
>
historyEvent := getDefaultHistoryEvent(eventID, version)
826
>
historyEvent.EventType = enumspb.EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_SIGNALED
827
>
historyEvent.Attributes = &historypb.HistoryEvent_ExternalWorkflowExecutionSignaledEventAttributes{ExternalWorkflowExecutionSignaledEventAttributes: &historypb.ExternalWorkflowExecutionSignaledEventAttributes{
828
>
InitiatedEventId: lastEvent.EventId,
829
>
Namespace: nsName.String(),
830
>
NamespaceId: nsID.String(),
831
>
WorkflowExecution: &commonpb.WorkflowExecution{
832
>
WorkflowId: lastEvent.GetSignalExternalWorkflowExecutionInitiatedEventAttributes().GetWorkflowExecution().WorkflowId,
833
>
RunId: lastEvent.GetSignalExternalWorkflowExecutionInitiatedEventAttributes().GetWorkflowExecution().RunId,
834
>
},
835
>
}}
836
>
return historyEvent
837
>
})
838
externalWorkflowCancel := NewHistoryEventVertex(enumspb.EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED.String())
839
externalWorkflowCancel.SetDataFunc(func(input ...any) any {