Skip to content

Commit 26a2029

Browse files
committed
fix(examples): add artificial sleeps to workflow example
fixes the pause/resume test Signed-off-by: mikeee <[email protected]>
1 parent dcf1bd6 commit 26a2029

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

examples/workflow/main.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,9 @@ func main() {
7676
log.Fatalf("failed to pause workflow: %v", err)
7777
}
7878

79-
respFetch, err := wfClient.FetchWorkflowMetadata(ctx, instanceID, workflow.WithFetchPayloads(true))
79+
time.Sleep(time.Second) // allow workflow to pause
80+
81+
respFetch, err := wfClient.FetchWorkflowMetadata(context.TODO(), instanceID, workflow.WithFetchPayloads(true))
8082
if err != nil {
8183
log.Fatalf("failed to fetch workflow: %v", err)
8284
}
@@ -93,7 +95,9 @@ func main() {
9395
log.Fatalf("failed to resume workflow: %v", err)
9496
}
9597

96-
respFetch, err = wfClient.FetchWorkflowMetadata(ctx, instanceID, workflow.WithFetchPayloads(true))
98+
time.Sleep(time.Second) // allow workflow to resume
99+
100+
respFetch, err = wfClient.FetchWorkflowMetadata(context.TODO(), instanceID, workflow.WithFetchPayloads(true))
97101
if err != nil {
98102
log.Fatalf("failed to get workflow: %v", err)
99103
}
@@ -141,7 +145,7 @@ func main() {
141145
log.Fatalf("failed to purge workflow: %v", err)
142146
}
143147

144-
respFetch, err = wfClient.FetchWorkflowMetadata(ctx, instanceID, workflow.WithFetchPayloads(true))
148+
respFetch, err = wfClient.FetchWorkflowMetadata(context.TODO(), instanceID, workflow.WithFetchPayloads(true))
145149
if err == nil || respFetch != nil {
146150
log.Fatalf("failed to purge workflow: %v", err)
147151
}

0 commit comments

Comments
 (0)