From 9d9d8b4d597e058af4ad9d56e0f96e73711e4e65 Mon Sep 17 00:00:00 2001 From: Michael Youssef Date: Wed, 3 Dec 2025 08:40:37 -0800 Subject: [PATCH 1/3] Wire in enableReplication into operator api --- go.mod | 2 +- go.sum | 4 ++-- service/frontend/operator_handler.go | 1 + 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index dd12769c8b..cf3e3c6700 100644 --- a/go.mod +++ b/go.mod @@ -58,7 +58,7 @@ require ( go.opentelemetry.io/otel/sdk v1.34.0 go.opentelemetry.io/otel/sdk/metric v1.34.0 go.opentelemetry.io/otel/trace v1.34.0 - go.temporal.io/api v1.58.1-0.20251128181858-703071215042 + go.temporal.io/api v1.58.1-0.20251203002935-472c572d9d48 go.temporal.io/sdk v1.35.0 go.uber.org/fx v1.24.0 go.uber.org/mock v0.6.0 diff --git a/go.sum b/go.sum index ea33209e43..bf9fb506b0 100644 --- a/go.sum +++ b/go.sum @@ -390,8 +390,8 @@ go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE= go.opentelemetry.io/proto/otlp v1.5.0 h1:xJvq7gMzB31/d406fB8U5CBdyQGw4P399D1aQWU/3i4= go.opentelemetry.io/proto/otlp v1.5.0/go.mod h1:keN8WnHxOy8PG0rQZjJJ5A2ebUoafqWp0eVQ4yIXvJ4= -go.temporal.io/api v1.58.1-0.20251128181858-703071215042 h1:44+nPe+rGhYUwA1oDi46rkXEYEVfoAxOmb0myvTm4Es= -go.temporal.io/api v1.58.1-0.20251128181858-703071215042/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM= +go.temporal.io/api v1.58.1-0.20251203002935-472c572d9d48 h1:Z7nNXZ+G5eHLpqsA/2sglxw1YbnjVQcYbndCskpkr8s= +go.temporal.io/api v1.58.1-0.20251203002935-472c572d9d48/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM= go.temporal.io/sdk v1.35.0 h1:lRNAQ5As9rLgYa7HBvnmKyzxLcdElTuoFJ0FXM/AsLQ= go.temporal.io/sdk v1.35.0/go.mod h1:1q5MuLc2MEJ4lneZTHJzpVebW2oZnyxoIOWX3oFVebw= go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ= diff --git a/service/frontend/operator_handler.go b/service/frontend/operator_handler.go index 60e95d1f63..af6563b6e3 100644 --- a/service/frontend/operator_handler.go +++ b/service/frontend/operator_handler.go @@ -655,6 +655,7 @@ func (h *OperatorHandlerImpl) AddOrUpdateRemoteCluster( InitialFailoverVersion: resp.GetInitialFailoverVersion(), IsGlobalNamespaceEnabled: resp.GetIsGlobalNamespaceEnabled(), IsConnectionEnabled: request.GetEnableRemoteClusterConnection(), + IsReplicationEnabled: request.GetEnableReplication(), Tags: resp.GetTags(), }, Version: updateRequestVersion, From 23bb0517440d7b80359e9c65a00ba1d5e41a3adf Mon Sep 17 00:00:00 2001 From: Michael Youssef Date: Wed, 3 Dec 2025 09:37:01 -0800 Subject: [PATCH 2/3] temp --- go.mod | 2 ++ go.sum | 2 -- service/frontend/operator_handler.go | 1 + tests/testcore/test_cluster.go | 2 +- 4 files changed, 4 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index cf3e3c6700..8e7b70ba0a 100644 --- a/go.mod +++ b/go.mod @@ -170,3 +170,5 @@ require ( modernc.org/mathutil v1.7.1 // indirect modernc.org/memory v1.11.0 // indirect ) + +replace go.temporal.io/api => /Users/michaely520/projects/api-go diff --git a/go.sum b/go.sum index bf9fb506b0..132ba1818c 100644 --- a/go.sum +++ b/go.sum @@ -390,8 +390,6 @@ go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE= go.opentelemetry.io/proto/otlp v1.5.0 h1:xJvq7gMzB31/d406fB8U5CBdyQGw4P399D1aQWU/3i4= go.opentelemetry.io/proto/otlp v1.5.0/go.mod h1:keN8WnHxOy8PG0rQZjJJ5A2ebUoafqWp0eVQ4yIXvJ4= -go.temporal.io/api v1.58.1-0.20251203002935-472c572d9d48 h1:Z7nNXZ+G5eHLpqsA/2sglxw1YbnjVQcYbndCskpkr8s= -go.temporal.io/api v1.58.1-0.20251203002935-472c572d9d48/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM= go.temporal.io/sdk v1.35.0 h1:lRNAQ5As9rLgYa7HBvnmKyzxLcdElTuoFJ0FXM/AsLQ= go.temporal.io/sdk v1.35.0/go.mod h1:1q5MuLc2MEJ4lneZTHJzpVebW2oZnyxoIOWX3oFVebw= go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ= diff --git a/service/frontend/operator_handler.go b/service/frontend/operator_handler.go index af6563b6e3..a6ecf4a442 100644 --- a/service/frontend/operator_handler.go +++ b/service/frontend/operator_handler.go @@ -725,6 +725,7 @@ func (h *OperatorHandlerImpl) ListClusters( InitialFailoverVersion: clusterResp.GetInitialFailoverVersion(), HistoryShardCount: clusterResp.GetHistoryShardCount(), IsConnectionEnabled: clusterResp.GetIsConnectionEnabled(), + IsReplicationEnabled: clusterResp.GetIsReplicationEnabled(), }) } return &operatorservice.ListClustersResponse{ diff --git a/tests/testcore/test_cluster.go b/tests/testcore/test_cluster.go index bc2bc10afa..1c4273450f 100644 --- a/tests/testcore/test_cluster.go +++ b/tests/testcore/test_cluster.go @@ -294,7 +294,7 @@ func newClusterWithPersistenceTestBaseFactory(t *testing.T, clusterConfig *TestC ClusterName: clusterName, ClusterId: clusterInfo.ClusterID, IsConnectionEnabled: clusterInfo.Enabled, - IsReplicationEnabled: clusterInfo.Enabled, + IsReplicationEnabled: clusterInfo.ReplicationEnabled, IsGlobalNamespaceEnabled: clusterMetadataConfig.EnableGlobalNamespace, FailoverVersionIncrement: clusterMetadataConfig.FailoverVersionIncrement, ClusterAddress: clusterInfo.RPCAddress, From 90128192fc8b26dd18ab861edcdee82f02ce69cf Mon Sep 17 00:00:00 2001 From: Michael Youssef Date: Thu, 4 Dec 2025 10:22:30 -0800 Subject: [PATCH 3/3] bump --- go.mod | 4 +--- go.sum | 2 ++ 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index 8e7b70ba0a..90babd6a6f 100644 --- a/go.mod +++ b/go.mod @@ -58,7 +58,7 @@ require ( go.opentelemetry.io/otel/sdk v1.34.0 go.opentelemetry.io/otel/sdk/metric v1.34.0 go.opentelemetry.io/otel/trace v1.34.0 - go.temporal.io/api v1.58.1-0.20251203002935-472c572d9d48 + go.temporal.io/api v1.59.1-0.20251203230651-7773526824c5 go.temporal.io/sdk v1.35.0 go.uber.org/fx v1.24.0 go.uber.org/mock v0.6.0 @@ -170,5 +170,3 @@ require ( modernc.org/mathutil v1.7.1 // indirect modernc.org/memory v1.11.0 // indirect ) - -replace go.temporal.io/api => /Users/michaely520/projects/api-go diff --git a/go.sum b/go.sum index 132ba1818c..e1902b4526 100644 --- a/go.sum +++ b/go.sum @@ -390,6 +390,8 @@ go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE= go.opentelemetry.io/proto/otlp v1.5.0 h1:xJvq7gMzB31/d406fB8U5CBdyQGw4P399D1aQWU/3i4= go.opentelemetry.io/proto/otlp v1.5.0/go.mod h1:keN8WnHxOy8PG0rQZjJJ5A2ebUoafqWp0eVQ4yIXvJ4= +go.temporal.io/api v1.59.1-0.20251203230651-7773526824c5 h1:7lFIrLVM+NPVcqFMrEwv5d8D9meA7n/Xl9GtCl8Gyhc= +go.temporal.io/api v1.59.1-0.20251203230651-7773526824c5/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM= go.temporal.io/sdk v1.35.0 h1:lRNAQ5As9rLgYa7HBvnmKyzxLcdElTuoFJ0FXM/AsLQ= go.temporal.io/sdk v1.35.0/go.mod h1:1q5MuLc2MEJ4lneZTHJzpVebW2oZnyxoIOWX3oFVebw= go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=