Update SDK to v1.15.0 (#2964)

temporalio · Jun 8, 2022 · 8610945 · 8610945
1 parent d3dc17e
commit 8610945
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 11 deletions.
diff --git a/common/sdk/factory.go b/common/sdk/factory.go
@@ -79,7 +79,7 @@ func (f *clientFactory) NewClient(namespaceName string, logger log.Logger) (sdkc
 
 	// Retry for up to 1m, handles frontend service not ready
 	err := backoff.Retry(func() error {
-		sdkClient, err := sdkclient.NewClient(sdkclient.Options{
+		sdkClient, err := sdkclient.Dial(sdkclient.Options{
 			HostPort:       f.hostPort,
 			Namespace:      namespaceName,
 			MetricsHandler: f.metricsHandler,

diff --git a/go.mod b/go.mod
@@ -41,7 +41,7 @@ require (
 	go.opentelemetry.io/otel/sdk v1.7.0
 	go.opentelemetry.io/otel/sdk/metric v0.30.0
 	go.temporal.io/api v1.8.1-0.20220603192404-e65836719706
-	go.temporal.io/sdk v1.14.1-0.20220525140819-54f4148173a9
+	go.temporal.io/sdk v1.15.0
 	go.temporal.io/version v0.3.0
 	go.uber.org/atomic v1.9.0
 	go.uber.org/fx v1.17.1

diff --git a/go.sum b/go.sum
@@ -481,11 +481,11 @@ go.opentelemetry.io/otel/sdk/metric v0.30.0/go.mod h1:8AKFRi5HyvTR0RRty3paN1aMC9
 go.opentelemetry.io/otel/trace v1.7.0 h1:O37Iogk1lEkMRXewVtZ1BBTVn5JEp8GrJvP92bJqC6o=
 go.opentelemetry.io/otel/trace v1.7.0/go.mod h1:fzLSB9nqR2eXzxPXb2JW9IKE+ScyXA48yyE4TNvoHqU=
 go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI=
-go.temporal.io/api v1.7.1-0.20220510183009-449d18444c9a/go.mod h1:YU5EQaONkIr0ZRju0NqdqYNH/hCkBuwqRMDA0iaj7JM=
+go.temporal.io/api v1.8.0/go.mod h1:7m1ZOVUFi/54a5IMzMeELnvDy5sJwRfz11zi3Jrww8w=
 go.temporal.io/api v1.8.1-0.20220603192404-e65836719706 h1:9zrW4CMQUgBMx9IUZ0qE/HhRxZEugmgvFTXBZhIdlsw=
 go.temporal.io/api v1.8.1-0.20220603192404-e65836719706/go.mod h1:7m1ZOVUFi/54a5IMzMeELnvDy5sJwRfz11zi3Jrww8w=
-go.temporal.io/sdk v1.14.1-0.20220525140819-54f4148173a9 h1:6XjIRR49O5FAXF6f64EP1N5VfCs8/IPIqXfXWQcRCp8=
-go.temporal.io/sdk v1.14.1-0.20220525140819-54f4148173a9/go.mod h1:d1S1ETFShrybdBYxhqizQASREk0G9oi4RE2VKsYGHAk=
+go.temporal.io/sdk v1.15.0 h1:1ZJEBNqLHAN0H64NpD4pydriYF9qhUIaimSVONm3ZKs=
+go.temporal.io/sdk v1.15.0/go.mod h1:peqnjALtNpJMKRplWEubefPhDXdAtRTnebsLSFypSts=
 go.temporal.io/version v0.3.0 h1:dMrei9l9NyHt8nG6EB8vAwDLLTwx2SvRyucCSumAiig=
 go.temporal.io/version v0.3.0/go.mod h1:UA9S8/1LaKYae6TyD9NaPMJTZb911JcbqghI2CBSP78=
 go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=

diff --git a/host/client_integration_test.go b/host/client_integration_test.go
@@ -95,7 +95,7 @@ func (s *clientIntegrationSuite) SetupTest() {
 	// Have to define our overridden assertions in the test setup. If we did it earlier, s.T() will return nil
 	s.Assertions = require.New(s.T())
 
-	sdkClient, err := sdkclient.NewClient(sdkclient.Options{
+	sdkClient, err := sdkclient.Dial(sdkclient.Options{
 		HostPort:  s.hostPort,
 		Namespace: s.namespace,
 	})
@@ -243,7 +243,7 @@ func testDataConverterWorkflow(ctx workflow.Context, tl string) (string, error)
 }
 
 func (s *clientIntegrationSuite) startWorkerWithDataConverter(tl string, dataConverter converter.DataConverter) (sdkclient.Client, worker.Worker) {
-	sdkClient, err := sdkclient.NewClient(sdkclient.Options{
+	sdkClient, err := sdkclient.Dial(sdkclient.Options{
 		HostPort:      s.hostPort,
 		Namespace:     s.namespace,
 		DataConverter: dataConverter,

diff --git a/host/xdc/integration_failover_test.go b/host/xdc/integration_failover_test.go
@@ -2233,7 +2233,7 @@ func (s *integrationClustersTestSuite) TestLocalNamespaceMigration() {
 	s.NoError(err)
 
 	// start force-replicate wf
-	sysClient, err := sdkclient.NewClient(sdkclient.Options{
+	sysClient, err := sdkclient.Dial(sdkclient.Options{
 		HostPort:  s.cluster1.GetHost().FrontendGRPCAddress(),
 		Namespace: "temporal-system",
 	})
@@ -2278,7 +2278,7 @@ func (s *integrationClustersTestSuite) TestLocalNamespaceMigration() {
 	s.Equal(clusterName[1], nsResp2.ReplicationConfig.ActiveClusterName)
 
 	// verify all wf in ns is now available in cluster2
-	client2, err := sdkclient.NewClient(sdkclient.Options{
+	client2, err := sdkclient.Dial(sdkclient.Options{
 		HostPort:  s.cluster2.GetHost().FrontendGRPCAddress(),
 		Namespace: namespace,
 	})
@@ -2349,7 +2349,7 @@ func (s *integrationClustersTestSuite) TestForceMigration_ClosedWorkflow() {
 	s.Equal(2, len(nsResp.ReplicationConfig.Clusters))
 
 	// Start force-replicate wf
-	sysClient, err := sdkclient.NewClient(sdkclient.Options{
+	sysClient, err := sdkclient.Dial(sdkclient.Options{
 		HostPort:  s.cluster1.GetHost().FrontendGRPCAddress(),
 		Namespace: "temporal-system",
 	})
@@ -2495,7 +2495,7 @@ func (s *integrationClustersTestSuite) registerNamespace(namespace string, isGlo
 }
 
 func (s *integrationClustersTestSuite) newClientAndWorker(hostport, namespace, taskqueue, identity string) (sdkclient.Client, sdkworker.Worker) {
-	sdkClient1, err := sdkclient.NewClient(sdkclient.Options{
+	sdkClient1, err := sdkclient.Dial(sdkclient.Options{
 		HostPort:  hostport,
 		Namespace: namespace,
 	})