diff --git a/internal/internal_task_pollers.go b/internal/internal_task_pollers.go index 6fbeb2732..71b6d759f 100644 --- a/internal/internal_task_pollers.go +++ b/internal/internal_task_pollers.go @@ -245,8 +245,10 @@ func (bp *basePoller) stopping() bool { } } -// doPoll runs the given pollFunc in a separate go routine. Returns when either of the conditions are met: -// - poll succeeds, poll fails or worker is stopping +// doPoll runs the given pollFunc in a separate go routine. Returns when any of the conditions are met: +// - poll succeeds +// - poll fails +// - worker is stopping func (bp *basePoller) doPoll(pollFunc func(ctx context.Context) (taskForWorker, error)) (taskForWorker, error) { if bp.stopping() { return nil, errStop diff --git a/workflow/doc.go b/workflow/doc.go index 83212c0ef..d94d93884 100644 --- a/workflow/doc.go +++ b/workflow/doc.go @@ -51,7 +51,7 @@ the sole parameter it receives as part of its initialization as a parameter to t func SimpleWorkflow(ctx workflow.Context, value string) error { ao := workflow.ActivityOptions{ - TaskQueue: "sampleTaskQueue", + TaskQueue: "sampleTaskQueue", ScheduleToCloseTimeout: time.Second * 60, ScheduleToStartTimeout: time.Second * 60, StartToCloseTimeout: time.Second * 60, @@ -149,7 +149,7 @@ The primary responsibility of the workflow implementation is to schedule activit straightforward way to do that is via the library method [workflow.ExecuteActivity]: ao := workflow.ActivityOptions{ - TaskQueue: "sampleTaskQueue", + TaskQueue: "sampleTaskQueue", ScheduleToCloseTimeout: time.Second * 60, ScheduleToStartTimeout: time.Second * 60, StartToCloseTimeout: time.Second * 60,