Client.NewPollingTaskRunner

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

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

workflows.TaskExecutor

required

The executor that reports task capabilities and executes leased tasks.

[]runner.Option

Options for initializing the polling runner.

Options

default:""

The cluster to poll for tasks. If not provided, the default cluster is used.

default:"slog.Default()"

Set the logger to use for the polling runner.

Returns

The created polling runner.

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

NewTaskRunner TaskExecutor

Python

Go

Client.NewPollingTaskRunner

Parameters

Options

Returns

​Parameters

​Options

​Returns

Parameters

Options

Returns