startWorkflow := firstOp.GetStartWorkflow()
if startWorkflow == nil {
// First operation is not StartWorkflow - try to get from UpdateWorkflow
routing_key_extractor.go
updateWorkflow := firstOp.GetUpdateWorkflow()
if updateWorkflow != nil && updateWorkflow.GetWorkflowExecution() != nil {
return namespace.RoutingKey{ID: updateWorkflow.GetWorkflowExecution().GetWorkflowId()}
}
return namespace.RoutingKey{}
}