81
return nil
82
}
84
>
85
>
if e.Config.EmitReplicationLifecycleEvents() {
86
emitReplicationExecuting(e.ProcessToolBox, e.ReplicationTask(), e.WorkflowKey, wideevents.ReplTaskSyncWorkflowState, int32(e.Attempt()))
87
}
88
90
>
namespaceName, apply, err := e.GetNamespaceInfo(headers.SetCallerInfo(
91
>
context.Background(),
92
>
callerInfo,
93
>
), e.NamespaceID, e.WorkflowID)
94
>
if err != nil {
95
return err
97
e.Logger.Warn("Skipping the replication task",
98
tag.WorkflowNamespaceID(e.NamespaceID),