Skip to content

Commit 13f56b1

Browse files
authored
Small sample fix
1 parent dddec49 commit 13f56b1

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

samples/scale/starter/main.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,10 @@ func startWorkflow(ctx context.Context, c client.Client, wg *sync.WaitGroup) {
5959

6060
// log.Println("Started workflow", wf.GetInstanceID())
6161

62-
c.WaitForWorkflowInstance(ctx, wf, time.Second*30)
62+
err = c.WaitForWorkflowInstance(ctx, wf, time.Second*30)
63+
if err != nil {
64+
log.Println("Received error while waiting for workflow", wf.GetInstanceID(), err)
65+
}
6366

6467
cn := atomic.AddInt32(&count, -1)
6568
log.Print(cn)

0 commit comments

Comments
 (0)