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)