Wire enableReplication into cli (#881)

## What was changed
Wiring in new enableReplication flag into cluster upsert cli.

Deleting sql pinning test as we no longer need this, see historical
context:

#784
temporalio/temporal#7333

then unpinning in OSS temporalio/temporal#8489

## Why?
Allows for users to leverage the new field

## Checklist

1. Closes 

2. How was this tested:
built locally and tested in conjunction with
temporalio/temporal#8744, used the cli manually
to make a replication based test pass

Author: michaely520

go.mod

@@ -16,7 +16,7 @@ require (
 	github.com/spf13/pflag v1.0.6
 	github.com/stretchr/testify v1.10.0
 	github.com/temporalio/ui-server/v2 v2.39.0
-	go.temporal.io/api v1.58.1-0.20251128181858-703071215042
+	go.temporal.io/api v1.59.1-0.20251203230651-7773526824c5
 	go.temporal.io/sdk v1.36.0
 	go.temporal.io/sdk/contrib/envconfig v0.1.0
 	go.temporal.io/server v1.29.0-135.0.0.20251210204203-56cbfb9a643c

go.sum

@@ -378,8 +378,8 @@ go.opentelemetry.io/otel/trace v1.35.0 h1:dPpEfJu1sDIqruz7BHFG3c7528f6ddfSWfFDVt
 go.opentelemetry.io/otel/trace v1.35.0/go.mod h1:WUk7DtFp1Aw2MkvqGdwiXYDZZNvA/1J8o6xRXLrIkyc=
 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.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.36.0 h1:WO9zetpybBNK7xsQth4Z+3Zzw1zSaM9MOUGrnnUjZMo=
 go.temporal.io/sdk v1.36.0/go.mod h1:8BxGRF0LcQlfQrLLGkgVajbsKUp/PY7280XTdcKc18Y=
 go.temporal.io/sdk/contrib/envconfig v0.1.0 h1:s+G/Ujph+Xl2jzLiiIm2T1vuijDkUL4Kse49dgDVGBE=

temporalcli/commands.gen.go

@@ -1256,10 +1256,11 @@ func NewTemporalOperatorClusterSystemCommand(cctx *CommandContext, parent *Tempo
 }
 
 type TemporalOperatorClusterUpsertCommand struct {
-	Parent           *TemporalOperatorClusterCommand
-	Command          cobra.Command
-	FrontendAddress  string
-	EnableConnection bool
+	Parent            *TemporalOperatorClusterCommand
+	Command           cobra.Command
+	FrontendAddress   string
+	EnableConnection  bool
+	EnableReplication bool
 }
 
 func NewTemporalOperatorClusterUpsertCommand(cctx *CommandContext, parent *TemporalOperatorClusterCommand) *TemporalOperatorClusterUpsertCommand {
@@ -1277,6 +1278,7 @@ func NewTemporalOperatorClusterUpsertCommand(cctx *CommandContext, parent *Tempo
 	s.Command.Flags().StringVar(&s.FrontendAddress, "frontend-address", "", "Remote endpoint. Required.")
 	_ = cobra.MarkFlagRequired(s.Command.Flags(), "frontend-address")
 	s.Command.Flags().BoolVar(&s.EnableConnection, "enable-connection", false, "Set the connection to \"enabled\".")
+	s.Command.Flags().BoolVar(&s.EnableReplication, "enable-replication", false, "Set the replication to \"enabled\".")
 	s.Command.Run = func(c *cobra.Command, args []string) {
 		if err := s.run(cctx, args); err != nil {
 			cctx.Options.Fail(err)

temporalcli/commands.operator_cluster.go

@@ -126,13 +126,14 @@ func (c *TemporalOperatorClusterListCommand) run(cctx *CommandContext, args []st
 					"HistoryShardCount":      cluster.HistoryShardCount,
 					"InitialFailoverVersion": cluster.InitialFailoverVersion,
 					"IsConnectionEnabled":    cluster.IsConnectionEnabled,
+					"IsReplicationEnabled":   cluster.IsReplicationEnabled,
 				})
 			}
 		}
 		// Print table, headers only on first table
 		if len(textTable) > 0 {
 			_ = cctx.Printer.PrintStructured(textTable, printer.StructuredOptions{
-				Fields: []string{"Name", "ClusterId", "Address", "HistoryShardCount", "InitialFailoverVersion", "IsConnectionEnabled"},
+				Fields: []string{"Name", "ClusterId", "Address", "HistoryShardCount", "InitialFailoverVersion", "IsConnectionEnabled", "IsReplicationEnabled"},
 				Table:  &printer.TableOptions{NoHeader: pageIndex > 0},
 			})
 		}
@@ -153,6 +154,7 @@ func (c *TemporalOperatorClusterUpsertCommand) run(cctx *CommandContext, args []
 	_, err = cl.OperatorService().AddOrUpdateRemoteCluster(cctx, &operatorservice.AddOrUpdateRemoteClusterRequest{
 		FrontendAddress:               c.FrontendAddress,
 		EnableRemoteClusterConnection: c.EnableConnection,
+		EnableReplication:             c.EnableReplication,
 	})
 	if err != nil {
 		return fmt.Errorf("unable to upsert cluster: %w", err)

temporalcli/commandsgen/commands.yml

@@ -1555,6 +1555,9 @@ commands:
       - name: enable-connection
         type: bool
         description: Set the connection to "enabled".
+      - name: enable-replication
+        type: bool
+        description: Set the replication to "enabled".
 
   - name: temporal operator namespace
     summary: Namespace operations