add comment

shijiesheng · shijiesheng · commit f49114ab1c2f · 2025-05-12T14:03:57.000-07:00
diff --git a/cmd/samples/batch/workflow.go b/cmd/samples/batch/workflow.go
@@ -49,6 +49,7 @@ func BatchWorkflow(ctx workflow.Context, input BatchWorkflowInput) error {
 		})
 		futures.Send(ctx, workflow.ExecuteActivity(aCtx, BatchActivity, taskID))
 	}
+	// close the channel to signal the task result collector that no more tasks are coming
 	futures.Close()
 
 	wg.Wait(ctx)

Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,7 @@ func BatchWorkflow(ctx workflow.Context, input BatchWorkflowInput) error {`
`49`	`49`	`})`
`50`	`50`	`futures.Send(ctx, workflow.ExecuteActivity(aCtx, BatchActivity, taskID))`
`51`	`51`	`}`
	`52`	`+ // close the channel to signal the task result collector that no more tasks are coming`
`52`	`53`	`futures.Close()`
`53`	`54`
`54`	`55`	`wg.Wait(ctx)`