Client.NewTaskRunner

runner, err := client.NewTaskRunner(ctx)

runner, err := client.NewTaskRunner(ctx)

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

Initialize a runner.

Parameters

[]runner.Option

Options for initializing the runner

default:""

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

default:"slog.Default()"

Set the logger to use for the runner

Disable OpenTelemetry metrics for the runner

The created runner object.

runner, err := client.NewTaskRunner(ctx)