Skip to main content
func (*Client) NewPollingTaskRunner(
    ctx context.Context,
    executor workflows.TaskExecutor,
    options ...runner.Option,
) (*workflows.PollingTaskRunner, error)
Create a polling runner for a custom task executor. Use this lower-level runner when you need a custom execution backend, such as a dynamic runtime, but still want the Tilebox polling protocol to request, lease, and report tasks.

​
Parameters

​
executor
workflows.TaskExecutor
required
The executor that reports task capabilities and executes leased tasks.
​
options
[]runner.Option
Options for initializing the polling runner.

​
Options

​
runner.WithClusterSlug(clusterSlug string)
default:""
The cluster to poll for tasks. If not provided, the default cluster is used.
​
runner.WithRunnerLogger(logger *slog.Logger)
default:"slog.Default()"
Set the logger to use for the polling runner.

​
Returns

The created polling runner. 
runner, err := client.NewPollingTaskRunner(ctx, executor)