1042
}
1043
1045
>
if duration := ms.namespaceEntry.Retention(); duration > 0 {
1046
retentionDuration = durationpb.New(duration)
1047
}
1048
>
initialBranchToken, err := ms.shard.GetExecutionManager().GetHistoryBranchUtil().NewHistoryBranch(
mutable_state_impl.go
1049
>
workflowKey.NamespaceID,
1050
>
workflowKey.WorkflowID,
1051
>
workflowKey.RunID,
1052
>
treeID,
1053
>
nil,
1054
>
[]*persistencespb.HistoryBranchRange{},
1055
>
runTimeout.AsDuration(),
1056
>
executionTimeout.AsDuration(),
1057
>
retentionDuration.AsDuration(),
1058
>
)
1059
>
if err != nil {
1060
return err
1061
}
1063
}
1064