627
}
628
630
>
executionState := workflowSnapshot.ExecutionState
631
>
632
>
namespaceID := executionInfo.NamespaceId
633
>
workflowID := executionInfo.WorkflowId
634
>
runID := executionState.RunId
635
>
workflowState := executionState.State
636
>
workflowStatus := executionState.Status
637
>
lastFirstEventID := executionInfo.LastFirstEventId
638
>
lastFirstEventTxnID := executionInfo.LastFirstEventTxnId
639
>
lastWorkflowTaskStartEventID := executionInfo.LastCompletedWorkflowTaskStartedEventId
640
>
nextEventID := workflowSnapshot.NextEventID
641
>
642
>
engine.NotifyNewHistoryEvent(events.NewNotification(
643
>
namespaceID,
644
>
&commonpb.WorkflowExecution{
645
>
WorkflowId: workflowID,
646
>
RunId: runID,
647
>
},
648
>
lastFirstEventID,
649
>
lastFirstEventTxnID,
650
>
nextEventID,
651
>
lastWorkflowTaskStartEventID,
652
>
workflowState,
653
>
workflowStatus,
654
>
executionInfo.VersionHistories,
655
>
executionInfo.TransitionHistory,
656
>
))
657
>
return nil
658
}
659