Allow update cluster address

temporalio · Jun 10, 2022 · 3ba4865 · 3ba4865
1 parent 05a90f8
commit 3ba4865
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/temporal/fx.go b/temporal/fx.go
@@ -639,11 +639,13 @@ func ApplyClusterMetadataConfigProvider(
 		}
 
 		// Allow updating cluster metadata if global namespace is disabled
-		if !resp.IsGlobalNamespaceEnabled && clusterData.EnableGlobalNamespace {
+		if (!resp.IsGlobalNamespaceEnabled && clusterData.EnableGlobalNamespace) ||
+			resp.ClusterAddress != clusterInfo.RPCAddress {
 			currentMetadata := resp.ClusterMetadata
 			currentMetadata.IsGlobalNamespaceEnabled = clusterData.EnableGlobalNamespace
 			currentMetadata.InitialFailoverVersion = clusterInfo.InitialFailoverVersion
 			currentMetadata.FailoverVersionIncrement = clusterData.FailoverVersionIncrement
+			currentMetadata.ClusterAddress = clusterInfo.RPCAddress
 
 			applied, err = clusterMetadataManager.SaveClusterMetadata(
 				ctx,