TaskRunner.Run

func (*TaskRunner) Run(ctx context.Context)

Run the task runner forever, looking for new tasks to run and polling for new tasks when idle.

Go

runner.Run(ctx)