Skip to content

Commit 21f5299

Browse files
JoshVanLJoshVanL
committed
Fixx
Signed-off-by: joshvanl <me@joshvanl.dev>
1 parent 58aa308 commit 21f5299

File tree

8 files changed

+238
-53
lines changed

8 files changed

+238
-53
lines changed

‎examples/go.mod‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,4 +37,4 @@ require (
3737
gopkg.in/yaml.v3 v3.0.1 // indirect
3838
)
3939

40-
replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250909233258-f612c96321f6
40+
replace github.com/dapr/durabletask-go => github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6

‎examples/go.sum‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,8 @@ github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
3434
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
3535
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
3636
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
37-
github.com/joshvanl/durabletask-go v0.0.0-20250909233258-f612c96321f6 h1:5uBYx3a4PezwpXCNpmLXq9NWFPF74zO/3oovhuG/4G8=
38-
github.com/joshvanl/durabletask-go v0.0.0-20250909233258-f612c96321f6/go.mod h1:0Ts4rXp74JyG19gDWPcwNo5V6NBZzhARzHF5XynmA7Q=
37+
github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6 h1:6jQhO49OJkcPrSd6muUU2KV2fsDh4OW3z0qB/TKmqJs=
38+
github.com/joshvanl/durabletask-go v0.0.0-20250910141618-db30df7b52d6/go.mod h1:0Ts4rXp74JyG19gDWPcwNo5V6NBZzhARzHF5XynmA7Q=
3939
github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
4040
github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
4141
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=

‎examples/workflow-parallel/main.go‎

Lines changed: 22 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -7,56 +7,59 @@ import (
77
"time"
88

99
"github.com/dapr/durabletask-go/workflow"
10-
dapr "github.com/dapr/go-sdk/client"
10+
"github.com/dapr/go-sdk/client"
1111
)
1212

1313
func main() {
14-
registry := workflow.NewTaskRegistry()
14+
r := workflow.NewRegistry()
1515

16-
if err := registry.AddWorkflow(BatchProcessingWorkflow); err != nil {
16+
if err := r.AddWorkflow(BatchProcessingWorkflow); err != nil {
1717
log.Fatalf("failed to register workflow: %v", err)
1818
}
19-
if err := registry.AddActivity(GetWorkBatch); err != nil {
19+
if err := r.AddActivity(GetWorkBatch); err != nil {
2020
log.Fatalf("failed to register activity: %v", err)
2121
}
22-
if err := registry.AddActivity(ProcessWorkItem); err != nil {
22+
if err := r.AddActivity(ProcessWorkItem); err != nil {
2323
log.Fatalf("failed to register activity: %v", err)
2424
}
25-
if err := registry.AddActivity(ProcessResults); err != nil {
25+
if err := r.AddActivity(ProcessResults); err != nil {
2626
log.Fatalf("failed to register activity: %v", err)
2727
}
2828
fmt.Println("Workflow(s) and activities registered.")
2929

30-
ctx := context.Background()
31-
32-
daprClient, err := dapr.NewClient()
30+
dclient, err := client.NewClient()
3331
if err != nil {
34-
log.Fatalf("failed to create Dapr client: %v", err)
32+
log.Fatal(err)
3533
}
3634

37-
wfclient := workflow.NewClient(daprClient.GrpcClientConn())
38-
if err := wfclient.StartWorker(ctx, registry); err != nil {
39-
log.Fatalf("failed to start work item listener: %v", err)
35+
wclient := workflow.NewClient(dclient.GrpcClientConn())
36+
fmt.Println("Worker initialized")
37+
38+
ctx, cancel := context.WithCancel(context.Background())
39+
defer cancel()
40+
41+
if err = wclient.StartWorker(ctx, r); err != nil {
42+
log.Fatal(err)
4043
}
4144

42-
id, err := wfclient.ScheduleNewWorkflow(ctx, "BatchProcessingWorkflow", workflow.WithInput(10))
45+
id, err := wclient.StartWorkflow(ctx, "BatchProcessingWorkflow", workflow.WithInput(10))
4346
if err != nil {
4447
log.Fatalf("failed to schedule a new workflow: %v", err)
4548
}
4649

47-
metadata, err := wfclient.WaitForWorkflowCompletion(ctx, id)
50+
metadata, err := wclient.WaitForWorkflowCompletion(ctx, id)
4851
if err != nil {
4952
log.Fatalf("failed to get workflow: %v", err)
5053
}
5154
fmt.Printf("workflow status: %s\n", metadata.RuntimeStatus.String())
5255

53-
err = wfclient.TerminateWorkflow(ctx, id)
56+
err = wclient.TerminateWorkflow(ctx, id)
5457
if err != nil {
5558
log.Fatalf("failed to terminate workflow: %v", err)
5659
}
5760
fmt.Println("workflow terminated")
5861

59-
err = wfclient.PurgeWorkflowState(ctx, id)
62+
err = wclient.PurgeWorkflowState(ctx, id)
6063
if err != nil {
6164
log.Fatalf("failed to purge workflow: %v", err)
6265
}
@@ -80,9 +83,9 @@ func BatchProcessingWorkflow(ctx *workflow.WorkflowContext) (any, error) {
8083
}
8184

8285
var outputs int
83-
for _, workflow := range parallelTasks {
86+
for _, task := range parallelTasks {
8487
var output int
85-
err := workflow.Await(&output)
88+
err := task.Await(&output)
8689
if err == nil {
8790
outputs += output
8891
} else {

‎examples/workflow-taskexecutionid/main.go‎

Lines changed: 18 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -9,49 +9,53 @@ import (
99
"time"
1010

1111
"github.com/dapr/durabletask-go/workflow"
12-
dapr "github.com/dapr/go-sdk/client"
12+
"github.com/dapr/go-sdk/client"
1313
)
1414

1515
func main() {
16-
registry := workflow.NewTaskRegistry()
16+
r := workflow.NewRegistry()
1717

18-
if err := registry.AddWorkflow(TaskExecutionIdWorkflow); err != nil {
18+
if err := r.AddWorkflow(TaskExecutionIdWorkflow); err != nil {
1919
log.Fatalf("failed to register workflow: %v", err)
2020
}
21-
if err := registry.AddActivity(RetryN); err != nil {
21+
if err := r.AddActivity(RetryN); err != nil {
2222
log.Fatalf("failed to register activity: %v", err)
2323
}
2424
fmt.Println("Workflow(s) and activities registered.")
2525

26-
daprClient, err := dapr.NewClient()
26+
dclient, err := client.NewClient()
2727
if err != nil {
28-
log.Fatalf("failed to create Dapr client: %v", err)
28+
log.Fatal(err)
2929
}
3030

31-
ctx := context.Background()
32-
wfclient := workflow.NewClient(daprClient.GrpcClientConn())
33-
if err := wfclient.StartWorker(ctx, registry); err != nil {
34-
log.Fatalf("failed to start work item listener: %v", err)
31+
wclient := workflow.NewClient(dclient.GrpcClientConn())
32+
fmt.Println("Worker initialized")
33+
34+
ctx, cancel := context.WithCancel(context.Background())
35+
defer cancel()
36+
37+
if err = wclient.StartWorker(ctx, r); err != nil {
38+
log.Fatal(err)
3539
}
3640

37-
id, err := wfclient.ScheduleNewWorkflow(ctx, "TaskExecutionIdWorkflow", workflow.WithInput(5))
41+
id, err := wclient.StartWorkflow(ctx, "TaskExecutionIdWorkflow", workflow.WithInput(5))
3842
if err != nil {
3943
log.Fatalf("failed to schedule a new workflow: %v", err)
4044
}
4145

42-
metadata, err := wfclient.WaitForWorkflowCompletion(ctx, id)
46+
metadata, err := wclient.WaitForWorkflowCompletion(ctx, id)
4347
if err != nil {
4448
log.Fatalf("failed to get workflow: %v", err)
4549
}
4650
fmt.Printf("workflow status: %s\n", metadata.RuntimeStatus.String())
4751

48-
err = wfclient.TerminateWorkflow(ctx, id)
52+
err = wclient.TerminateWorkflow(ctx, id)
4953
if err != nil {
5054
log.Fatalf("failed to terminate workflow: %v", err)
5155
}
5256
fmt.Println("workflow terminated")
5357

54-
err = wfclient.PurgeWorkflowState(ctx, id)
58+
err = wclient.PurgeWorkflowState(ctx, id)
5559
if err != nil {
5660
log.Fatalf("failed to purge workflow: %v", err)
5761
}

0 commit comments

Comments
 (0)