Update SDK to v1.15.0 (#200)

temporalio · Jun 8, 2022 · f334c48 · f334c48
1 parent b49280d
commit f334c48
Show file tree

Hide file tree

Showing 97 changed files with 126 additions and 117 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -16,6 +16,6 @@ jobs:
           submodules: recursive
       - uses: actions/setup-go@v2
         with:
-          go-version: "1.17"
+          go-version: "1.18"
       - name: CI Build
         run: make ci-build
diff --git a/branch/starter/main.go b/branch/starter/main.go
@@ -12,7 +12,7 @@ import (
 // @@@SNIPSTART samples-go-branch-workflow-execution-starter
 func main() {
 	// The client is a heavyweight object that should be created only once per process.
-	c, err := client.NewClient(client.Options{})
+	c, err := client.Dial(client.Options{})
 	if err != nil {
 		panic(err)
 	}

diff --git a/branch/worker/main.go b/branch/worker/main.go
@@ -12,7 +12,7 @@ import (
 // @@@SNIPSTART samples-go-branch-worker-starter
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/cancellation/cancel/main.go b/cancellation/cancel/main.go
@@ -20,7 +20,7 @@ func main() {
 	}
 
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/cancellation/starter/main.go b/cancellation/starter/main.go
@@ -17,7 +17,7 @@ func main() {
 	flag.Parse()
 
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/cancellation/worker/main.go b/cancellation/worker/main.go
@@ -12,7 +12,7 @@ import (
 // @@@SNIPSTART samples-go-cancellation-worker-starter
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/child-workflow-continue-as-new/starter/main.go b/child-workflow-continue-as-new/starter/main.go
@@ -13,7 +13,7 @@ import (
 // @@@SNIPSTART samples-go-cw-cas-workflow-execution-starter
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/child-workflow-continue-as-new/worker/main.go b/child-workflow-continue-as-new/worker/main.go
@@ -12,7 +12,7 @@ import (
 // @@@SNIPSTART samples-go-cw-cas-worker-starter
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/child-workflow/starter/main.go b/child-workflow/starter/main.go
@@ -13,7 +13,7 @@ import (
 // @@@SNIPSTART samples-go-child-workflow-example-execution-starter
 func main() {
 	// The client is a heavyweight object that should be created only once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/child-workflow/worker/main.go b/child-workflow/worker/main.go
@@ -12,7 +12,7 @@ import (
 // @@@SNIPSTART samples-go-child-workflow-example-worker-starter
 func main() {
 	// The client is a heavyweight object that should be created only once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/choice-exclusive/starter/main.go b/choice-exclusive/starter/main.go
@@ -12,7 +12,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/choice-exclusive/worker/main.go b/choice-exclusive/worker/main.go
@@ -11,7 +11,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/choice-multi/starter/main.go b/choice-multi/starter/main.go
@@ -12,7 +12,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/choice-multi/worker/main.go b/choice-multi/worker/main.go
@@ -11,7 +11,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/codec-server/starter/main.go b/codec-server/starter/main.go
@@ -10,7 +10,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		// Set DataConverter here to ensure that workflow inputs and results are
 		// encoded as required.
 		DataConverter: codecserver.DataConverter,

diff --git a/codec-server/worker/main.go b/codec-server/worker/main.go
@@ -10,7 +10,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		// Set DataConverter here so that workflow and activity inputs/results will
 		// be compressed as required.
 		DataConverter: codecserver.DataConverter,

diff --git a/cron/starter/main.go b/cron/starter/main.go
@@ -12,7 +12,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/cron/worker/main.go b/cron/worker/main.go
@@ -11,7 +11,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/ctxpropagation/starter/main.go b/ctxpropagation/starter/main.go
@@ -25,7 +25,7 @@ func main() {
 	}
 
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort:           client.DefaultHostPort,
 		Interceptors:       []interceptor.ClientInterceptor{tracingInterceptor},
 		ContextPropagators: []workflow.ContextPropagator{ctxpropagation.NewContextPropagator()},

diff --git a/ctxpropagation/worker/main.go b/ctxpropagation/worker/main.go
@@ -24,7 +24,7 @@ func main() {
 	}
 
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort:           client.DefaultHostPort,
 		ContextPropagators: []workflow.ContextPropagator{ctxpropagation.NewContextPropagator()},
 		Interceptors:       []interceptor.ClientInterceptor{tracingInterceptor},

diff --git a/dsl/starter/main.go b/dsl/starter/main.go
@@ -28,7 +28,7 @@ func main() {
 	}
 
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/dsl/worker/main.go b/dsl/worker/main.go
@@ -11,7 +11,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/dynamic/starter/main.go b/dynamic/starter/main.go
@@ -10,7 +10,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/dynamic/worker/main.go b/dynamic/worker/main.go
@@ -11,7 +11,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/encryption/starter/main.go b/encryption/starter/main.go
@@ -13,7 +13,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		// If you intend to use the same encryption key for all workflows you can
 		// set the KeyID for the encryption encoder like so:
 		//

diff --git a/encryption/worker/main.go b/encryption/worker/main.go
@@ -12,7 +12,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		// If you intend to use the same encryption key for all workflows you can
 		// set the KeyID for the encryption encoder like so:
 		//

diff --git a/expense/server/main.go b/expense/server/main.go
@@ -32,7 +32,7 @@ var (
 func main() {
 	var err error
 	// The client is a heavyweight object that should be created once per process.
-	workflowClient, err = client.NewClient(client.Options{
+	workflowClient, err = client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/expense/starter/main.go b/expense/starter/main.go
@@ -12,7 +12,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/expense/worker/main.go b/expense/worker/main.go
@@ -11,7 +11,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/fileprocessing/starter/main.go b/fileprocessing/starter/main.go
@@ -12,7 +12,7 @@ import (
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/fileprocessing/worker/main.go b/fileprocessing/worker/main.go
@@ -11,7 +11,7 @@ import (
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.NewClient(client.Options{
+	c, err := client.Dial(client.Options{
 		HostPort: client.DefaultHostPort,
 	})
 	if err != nil {

diff --git a/go.mod b/go.mod
@@ -13,19 +13,19 @@ require (
 	github.com/opentracing/opentracing-go v1.2.0
 	github.com/pborman/uuid v1.2.1
 	github.com/prometheus/client_golang v1.12.1
-	github.com/stretchr/testify v1.7.0
+	github.com/stretchr/testify v1.7.1
 	github.com/uber-go/tally/v4 v4.1.1
 	github.com/uber/jaeger-client-go v2.29.1+incompatible
 	github.com/uber/jaeger-lib v2.4.1+incompatible // indirect
-	go.temporal.io/api v1.7.1-0.20220223032354-6e6fe738916a
-	go.temporal.io/sdk v1.14.0
+	go.temporal.io/api v1.8.0
+	go.temporal.io/sdk v1.15.0
 	go.temporal.io/sdk/contrib/opentracing v0.1.0
 	go.temporal.io/sdk/contrib/tally v0.1.0
 	go.temporal.io/sdk/contrib/tools/workflowcheck v0.0.0-20220331154559-fd0d1eb548eb
 	go.temporal.io/server v1.15.2
 	go.uber.org/zap v1.20.0
-	google.golang.org/grpc v1.44.0
+	google.golang.org/grpc v1.47.0
 	gopkg.in/check.v1 v1.0.0-20200902074654-038fdea0a05b // indirect
 	gopkg.in/square/go-jose.v2 v2.6.0
-	gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b
+	gopkg.in/yaml.v3 v3.0.1
 )