Add pause/unpause commands (#885)

<!--- Note to EXTERNAL Contributors -->
<!-- Thanks for opening a PR! 
If it is a significant code change, please **make sure there is an open
issue** for this.
We work best with you when we have accepted the idea first before you
code. -->

<!--- For ALL Contributors 👇 -->

## What was changed
Added 2 new commands (experimental)
- temporal workflow pause
- temporal workflow unpause

Did a bunch of unrelated cleanup as well.

## Why?
Need these commands to allow pausing and unpausing of workflows via cli

## Checklist
<!--- add/delete as needed --->

1. Closes <!-- add issue number here -->

2. How was this tested:
<!--- Please describe how you tested your changes/how we can test them
-->

3. Any docs updates needed?
<!--- update README if applicable
      or point out where to update docs.temporal.io -->

Author: gow

go.mod

@@ -10,20 +10,20 @@ require (
 	github.com/fatih/color v1.18.0
 	github.com/google/uuid v1.6.0
 	github.com/mattn/go-isatty v0.0.20
-	github.com/nexus-rpc/sdk-go v0.3.0
+	github.com/nexus-rpc/sdk-go v0.5.1
 	github.com/olekukonko/tablewriter v0.0.5
 	github.com/spf13/cobra v1.9.1
 	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.53.0
+	go.temporal.io/api v1.58.1-0.20251128181858-703071215042
 	go.temporal.io/sdk v1.36.0
 	go.temporal.io/sdk/contrib/envconfig v0.1.0
-	go.temporal.io/server v1.29.0
+	go.temporal.io/server v1.29.0-135.0.0.20251210204203-56cbfb9a643c
 	google.golang.org/grpc v1.72.2
 	google.golang.org/protobuf v1.36.6
 	gopkg.in/yaml.v3 v3.0.1
-	modernc.org/sqlite v1.34.1
+	modernc.org/sqlite v1.39.1
 )
 
 require (
@@ -44,7 +44,7 @@ require (
 	github.com/Masterminds/semver/v3 v3.3.0 // indirect
 	github.com/Masterminds/sprig/v3 v3.3.0 // indirect
 	github.com/apache/thrift v0.21.0 // indirect
-	github.com/aws/aws-sdk-go v1.55.6 // indirect
+	github.com/aws/aws-sdk-go v1.55.8 // indirect
 	github.com/benbjohnson/clock v1.3.5 // indirect
 	github.com/beorn7/perks v1.0.1 // indirect
 	github.com/blang/semver/v4 v4.0.0 // indirect
@@ -70,7 +70,6 @@ require (
 	github.com/golang/mock v1.7.0-rc.1 // indirect
 	github.com/golang/snappy v1.0.0 // indirect
 	github.com/gomarkdown/markdown v0.0.0-20250311123330-531bef5e742b // indirect
-	github.com/google/pprof v0.0.0-20250317173921-a4b03ec1a45e // indirect
 	github.com/google/s2a-go v0.1.9 // indirect
 	github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect
 	github.com/googleapis/gax-go/v2 v2.14.1 // indirect
@@ -79,7 +78,6 @@ require (
 	github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.3.2 // indirect
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.3 // indirect
 	github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed // indirect
-	github.com/hashicorp/golang-lru/v2 v2.0.7 // indirect
 	github.com/huandu/xstrings v1.5.0 // indirect
 	github.com/iancoleman/strcase v0.3.0 // indirect
 	github.com/inconshreveable/mousetrap v1.1.0 // indirect
@@ -104,7 +102,6 @@ require (
 	github.com/ncruces/go-strftime v0.1.9 // indirect
 	github.com/olivere/elastic/v7 v7.0.32 // indirect
 	github.com/opentracing/opentracing-go v1.2.0 // indirect
-	github.com/pborman/uuid v1.2.1 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10 // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
@@ -147,17 +144,17 @@ require (
 	go.opentelemetry.io/otel/trace v1.35.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.5.0 // indirect
 	go.uber.org/atomic v1.11.0 // indirect
-	go.uber.org/dig v1.18.1 // indirect
-	go.uber.org/fx v1.23.0 // indirect
-	go.uber.org/mock v0.5.0 // indirect
+	go.uber.org/dig v1.19.0 // indirect
+	go.uber.org/fx v1.24.0 // indirect
+	go.uber.org/mock v0.6.0 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
 	go.uber.org/zap v1.27.0 // indirect
 	golang.org/x/crypto v0.38.0 // indirect
-	golang.org/x/exp v0.0.0-20250305212735-054e65f0b394 // indirect
+	golang.org/x/exp v0.0.0-20250620022241-b7579e27df2b // indirect
 	golang.org/x/net v0.40.0 // indirect
 	golang.org/x/oauth2 v0.30.0 // indirect
-	golang.org/x/sync v0.14.0 // indirect
-	golang.org/x/sys v0.33.0 // indirect
+	golang.org/x/sync v0.16.0 // indirect
+	golang.org/x/sys v0.37.0 // indirect
 	golang.org/x/text v0.25.0 // indirect
 	golang.org/x/time v0.11.0 // indirect
 	google.golang.org/api v0.228.0 // indirect
@@ -166,12 +163,7 @@ require (
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250324211829-b45e905df463 // indirect
 	gopkg.in/inf.v0 v0.9.1 // indirect
 	gopkg.in/validator.v2 v2.0.1 // indirect
-	modernc.org/cc/v4 v4.25.2 // indirect
-	modernc.org/gc/v2 v2.6.5 // indirect
-	modernc.org/gc/v3 v3.0.0 // indirect
-	modernc.org/libc v1.55.3 // indirect
+	modernc.org/libc v1.66.10 // indirect
 	modernc.org/mathutil v1.7.1 // indirect
-	modernc.org/memory v1.9.1 // indirect
-	modernc.org/strutil v1.2.1 // indirect
-	modernc.org/token v1.1.0 // indirect
+	modernc.org/memory v1.11.0 // indirect
 )

go.sum

@@ -0,0 +1,48 @@
+package temporalcli
+
+import (
+	"go.temporal.io/api/workflowservice/v1"
+)
+
+func (c *TemporalWorkflowPauseCommand) run(cctx *CommandContext, args []string) error {
+	cl, err := c.Parent.ClientOptions.dialClient(cctx)
+	if err != nil {
+		return err
+	}
+	defer cl.Close()
+
+	_, err = cl.WorkflowService().PauseWorkflowExecution(cctx, &workflowservice.PauseWorkflowExecutionRequest{
+		Namespace:  c.Parent.Namespace,
+		Reason:     c.Reason,
+		WorkflowId: c.WorkflowId,
+		RunId:      c.RunId,
+		Identity:   c.Parent.Identity,
+	})
+	if err != nil {
+		return err
+	}
+
+	cctx.Printer.Println("Workflow Execution paused")
+	return nil
+}
+
+func (c *TemporalWorkflowUnpauseCommand) run(cctx *CommandContext, args []string) error {
+	cl, err := c.Parent.ClientOptions.dialClient(cctx)
+	if err != nil {
+		return err
+	}
+	defer cl.Close()
+
+	_, err = cl.WorkflowService().UnpauseWorkflowExecution(cctx, &workflowservice.UnpauseWorkflowExecutionRequest{
+		Namespace:  c.Parent.Namespace,
+		Reason:     c.Reason,
+		WorkflowId: c.WorkflowId,
+		RunId:      c.RunId,
+		Identity:   c.Parent.Identity,
+	})
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

temporalcli/commands.gen.go

@@ -19,7 +19,7 @@ import (
 	"go.temporal.io/sdk/worker"
 	"go.temporal.io/sdk/workflow"
 	"go.temporal.io/server/common/rpc"
-	"go.temporal.io/server/common/searchattribute"
+	"go.temporal.io/server/common/searchattribute/sadefs"
 	"go.temporal.io/server/common/worker_versioning"
 )
 
@@ -871,8 +871,8 @@ func (sut *batchResetTestData) waitBlockOnNonDeterministicError() {
 
 	// wait for it to appear in visibility
 	query := fmt.Sprintf(`%s = "%s" and %s = "%s"`,
-		searchattribute.ExecutionStatus, "Running",
-		searchattribute.BuildIds, worker_versioning.UnversionedBuildIdSearchAttribute(sut.internalVersionFor("v2")))
+		sadefs.ExecutionStatus, "Running",
+		sadefs.BuildIds, worker_versioning.UnversionedBuildIdSearchAttribute(sut.internalVersionFor("v2")))
 	sut.assert.Eventually(func() bool {
 		resp, err := sut.client.ListWorkflow(sut.ctx, &workflowservice.ListWorkflowExecutionsRequest{
 			Namespace: sut.namespace,

temporalcli/commands.workflow_pause.go

@@ -360,7 +360,7 @@ commands:
 
       Either `activity-id`, `activity-type`, or `--match-all` must be specified.
 
-      Activity options can be updated in bulk with a visibility query list filter. 
+      Activity options can be updated in bulk with a visibility query list filter.
       For example, if you want to reset for activities of type Foo, do:
 
       ```
@@ -592,7 +592,7 @@ commands:
 
       Either `activity-id`, `activity-type`, or `--match-all` must be specified.
 
-      Activities can be reset in bulk with a visibility query list filter. 
+      Activities can be reset in bulk with a visibility query list filter.
       For example, if you want to reset activities of type Foo:
 
       ```
@@ -4248,6 +4248,34 @@ commands:
         description: |
           Assume update inputs are base64-encoded and attempt to decode them.
 
+  - name: temporal workflow pause
+    summary: 'Pause a Workflow Execution (Experimental feature)'
+    description: |
+      Pause a Workflow Execution.
+      Note: This is an experimental feature and may change in the future.
+    options:
+      - name: reason
+        type: string
+        description: |
+          Reason for pausing the Workflow Execution.
+          Defaults to message with the current user's name.
+    option-sets:
+      - workflow-reference
+
+  - name: temporal workflow unpause
+    summary: 'Unpause a previously paused Workflow Execution (Experimental feature)'
+    description: |
+      Unpause a previously paused Workflow Execution.
+      Note: This is an experimental feature and may change in the future.
+    options:
+      - name: reason
+        type: string
+        description: |
+          Reason for unpausing the Workflow Execution.
+          Defaults to message with the current user's name.
+    option-sets:
+      - workflow-reference
+
 option-sets:
   - name: client
     options:

temporalcli/commands.workflow_reset_test.go

@@ -246,7 +246,7 @@ func (s *StartOptions) buildServerOptions() ([]temporal.ServerOption, error) {
 
 	// Dynamic config if set
 	for k, v := range s.DynamicConfigValues {
-		dynConf[dynamicconfig.Key(k)] = v
+		dynConf[dynamicconfig.MakeKey(k)] = v
 	}
 	opts = append(opts, temporal.WithDynamicConfigClient(dynConf))