fix(examples): add artificial sleeps to workflow example

fixes the pause/resume test Signed-off-by: mikeee <[email protected]>
dapr · Jan 29, 2025 · 26a2029 · 26a2029
1 parent dcf1bd6
commit 26a2029
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/examples/workflow/main.go b/examples/workflow/main.go
@@ -76,7 +76,9 @@ func main() {
 		log.Fatalf("failed to pause workflow: %v", err)
 	}
 
-	respFetch, err := wfClient.FetchWorkflowMetadata(ctx, instanceID, workflow.WithFetchPayloads(true))
+	time.Sleep(time.Second) // allow workflow to pause
+
+	respFetch, err := wfClient.FetchWorkflowMetadata(context.TODO(), instanceID, workflow.WithFetchPayloads(true))
 	if err != nil {
 		log.Fatalf("failed to fetch workflow: %v", err)
 	}
@@ -93,7 +95,9 @@ func main() {
 		log.Fatalf("failed to resume workflow: %v", err)
 	}
 
-	respFetch, err = wfClient.FetchWorkflowMetadata(ctx, instanceID, workflow.WithFetchPayloads(true))
+	time.Sleep(time.Second) // allow workflow to resume
+
+	respFetch, err = wfClient.FetchWorkflowMetadata(context.TODO(), instanceID, workflow.WithFetchPayloads(true))
 	if err != nil {
 		log.Fatalf("failed to get workflow: %v", err)
 	}
@@ -141,7 +145,7 @@ func main() {
 		log.Fatalf("failed to purge workflow: %v", err)
 	}
 
-	respFetch, err = wfClient.FetchWorkflowMetadata(ctx, instanceID, workflow.WithFetchPayloads(true))
+	respFetch, err = wfClient.FetchWorkflowMetadata(context.TODO(), instanceID, workflow.WithFetchPayloads(true))
 	if err == nil || respFetch != nil {
 		log.Fatalf("failed to purge workflow: %v", err)
 	}