Expose workflow client in go-sdk

JoshVanL · JoshVanL · commit 0f452bd4b56a · 2025-09-10T11:00:24.000-04:00
Signed-off-by: joshvanl &lt;me@joshvanl.dev&gt;
diff --git a/client/client.go b/client/client.go
@@ -27,6 +27,7 @@ import (
 	"sync"
 	"time"
 
+	"github.com/dapr/durabletask-go/workflow"
 	"github.com/dapr/go-sdk/actor"
 	"github.com/dapr/go-sdk/actor/config"
 	"github.com/dapr/go-sdk/client/internal"
@@ -288,6 +289,15 @@ func NewClient() (client Client, err error) {
 	return defaultClient, nil
 }
 
+func NewWorkflowClient() (*workflow.Client, error) {
+	dclient, err := NewClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return workflow.NewClient(dclient.GrpcClientConn()), nil
+}
+
 // NewClientWithPort instantiates Dapr using specific gRPC port.
 func NewClientWithPort(port string) (client Client, err error) {
 	if port == "" {
diff --git a/examples/go.mod b/examples/go.mod
@@ -37,4 +37,4 @@ require (
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )
 
-replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6
+replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3
diff --git a/examples/go.sum b/examples/go.sum
@@ -34,8 +34,8 @@ github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
 github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6 h1:6jQhO49OJkcPrSd6muUU2KV2fsDh4OW3z0qB/TKmqJs=
-github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6/go.mod h1:0Ts4rXp74JyG19gDWPcwNo5V6NBZzhARzHF5XynmA7Q=
+github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3 h1:pJl5ptC8ovsxT5aMREpoP/CBpPj1KmmLj2+lUSJDBnw=
+github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3/go.mod h1:0Ts4rXp74JyG19gDWPcwNo5V6NBZzhARzHF5XynmA7Q=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
diff --git a/examples/workflow-parallel/main.go b/examples/workflow-parallel/main.go
@@ -27,12 +27,10 @@ func main() {
 	}
 	fmt.Println("Workflow(s) and activities registered.")
 
-	dclient, err := client.NewClient()
+	wclient, err := client.NewWorkflowClient()
 	if err != nil {
 		log.Fatal(err)
 	}
-
-	wclient := workflow.NewClient(dclient.GrpcClientConn())
 	fmt.Println("Worker initialized")
 
 	ctx, cancel := context.WithCancel(context.Background())
diff --git a/examples/workflow-taskexecutionid/main.go b/examples/workflow-taskexecutionid/main.go
@@ -23,12 +23,10 @@ func main() {
 	}
 	fmt.Println("Workflow(s) and activities registered.")
 
-	dclient, err := client.NewClient()
+	wclient, err := client.NewWorkflowClient()
 	if err != nil {
 		log.Fatal(err)
 	}
-
-	wclient := workflow.NewClient(dclient.GrpcClientConn())
 	fmt.Println("Worker initialized")
 
 	ctx, cancel := context.WithCancel(context.Background())
diff --git a/examples/workflow/main.go b/examples/workflow/main.go
@@ -46,12 +46,10 @@ func main() {
 	}
 	fmt.Println("FailActivity registered")
 
-	dclient, err := client.NewClient()
+	wclient, err := client.NewWorkflowClient()
 	if err != nil {
 		log.Fatal(err)
 	}
-
-	wclient := workflow.NewClient(dclient.GrpcClientConn())
 	fmt.Println("Worker initialized")
 
 	ctx, cancel := context.WithCancel(context.Background())
diff --git a/go.mod b/go.mod
@@ -31,4 +31,4 @@ require (
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250603155806-513f23925822 // indirect
 )
 
-replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6
+replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3
diff --git a/go.sum b/go.sum
@@ -21,8 +21,8 @@ github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
 github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6 h1:6jQhO49OJkcPrSd6muUU2KV2fsDh4OW3z0qB/TKmqJs=
-github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6/go.mod h1:0Ts4rXp74JyG19gDWPcwNo5V6NBZzhARzHF5XynmA7Q=
+github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3 h1:pJl5ptC8ovsxT5aMREpoP/CBpPj1KmmLj2+lUSJDBnw=
+github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3/go.mod h1:0Ts4rXp74JyG19gDWPcwNo5V6NBZzhARzHF5XynmA7Q=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=

Original file line number	Diff line number	Diff line change
`@@ -37,4 +37,4 @@ require (`
`37`	`37`	`gopkg.in/yaml.v3 v3.0.1 // indirect`
`38`	`38`	`)`
`39`	`39`
`40`		`-replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6`
	`40`	`+replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3`
Original file line number	Diff line number	Diff line change
`@@ -27,12 +27,10 @@ func main() {`
`27`	`27`	`}`
`28`	`28`	`fmt.Println("Workflow(s) and activities registered.")`
`29`	`29`
`30`		`- dclient, err := client.NewClient()`
	`30`	`+ wclient, err := client.NewWorkflowClient()`
`31`	`31`	`if err != nil {`
`32`	`32`	`log.Fatal(err)`
`33`	`33`	`}`
`34`		`-`
`35`		`- wclient := workflow.NewClient(dclient.GrpcClientConn())`
`36`	`34`	`fmt.Println("Worker initialized")`
`37`	`35`
`38`	`36`	`ctx, cancel := context.WithCancel(context.Background())`
Original file line number	Diff line number	Diff line change
`@@ -23,12 +23,10 @@ func main() {`
`23`	`23`	`}`
`24`	`24`	`fmt.Println("Workflow(s) and activities registered.")`
`25`	`25`
`26`		`- dclient, err := client.NewClient()`
	`26`	`+ wclient, err := client.NewWorkflowClient()`
`27`	`27`	`if err != nil {`
`28`	`28`	`log.Fatal(err)`
`29`	`29`	`}`
`30`		`-`
`31`		`- wclient := workflow.NewClient(dclient.GrpcClientConn())`
`32`	`30`	`fmt.Println("Worker initialized")`
`33`	`31`
`34`	`32`	`ctx, cancel := context.WithCancel(context.Background())`
Original file line number	Diff line number	Diff line change
`@@ -46,12 +46,10 @@ func main() {`
`46`	`46`	`}`
`47`	`47`	`fmt.Println("FailActivity registered")`
`48`	`48`
`49`		`- dclient, err := client.NewClient()`
	`49`	`+ wclient, err := client.NewWorkflowClient()`
`50`	`50`	`if err != nil {`
`51`	`51`	`log.Fatal(err)`
`52`	`52`	`}`
`53`		`-`
`54`		`- wclient := workflow.NewClient(dclient.GrpcClientConn())`
`55`	`53`	`fmt.Println("Worker initialized")`
`56`	`54`
`57`	`55`	`ctx, cancel := context.WithCancel(context.Background())`
Original file line number	Diff line number	Diff line change
`@@ -31,4 +31,4 @@ require (`
`31`	`31`	`google.golang.org/genproto/googleapis/rpc v0.0.0-20250603155806-513f23925822 // indirect`
`32`	`32`	`)`
`33`	`33`
`34`		`-replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6`
	`34`	`+replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910145333-8c0bbac241c3`