TaskRunner.RunAll

if err := runner.RunAll(ctx); err != nil {
    return err
}

func (*TaskRunner) RunAll(ctx context.Context) error

Run the runner until there are no more tasks available. Use RunAll for finite worker processes and local draining workflows. Use RunForever for long-running runners.

Parameters

ctx

context.Context

required

The context controlling the runner lifetime.

Returns

An error if the polling loop fails.

if err := runner.RunAll(ctx); err != nil {
    return err
}

TaskRunner.RunForever PollingTaskRunner.RunForever

Python

Go

Parameters

Returns

​Parameters

​Returns

Parameters

Returns