runner, err := client.NewTaskRunner(ctx)
func (*Client) NewTaskRunner(
  ctx context.Context,
  options ...runner.Option,
) (*workflows.TaskRunner, error)

Initialize a task runner.

Parameters

options
[]runner.Option

Options for initializing the task runner

Options

WithClusterSlug(clusterSlug string)
default:""

The cluster to connect to. If not provided, the default cluster is used.

WithRunnerLogger(logger *slog.Logger)
default:"slog.Default()"

Set the logger to use for the task runner

WithDisableMetrics()

Disable OpenTelemetry metrics for the task runner

Returns

The created task runner object.

runner, err := client.NewTaskRunner(ctx)