return nil
}
mutableState.AddSignalRequested(request.GetRequestId())
}
if _, err := mutableState.AddWorkflowExecutionSignaled(
request.GetSignalName(),
request.GetSignalInput(),
request.GetIdentity(),
request.GetHeader(),
request.GetRequestId(),
request.GetLinks(),
); err != nil {
return err
}
// Create a transfer task to schedule a workflow task
if !mutableState.HasPendingWorkflowTask() && !mutableState.IsWorkflowExecutionStatusPaused() {
signal_with_start_workflow.go
executionInfo := mutableState.GetExecutionInfo()