Method Run

backend/runner/taskrun/scheduler.go:155–169

Run will start the scheduler.

(ctx context.Context, wg *sync.WaitGroup)

// Run will start the scheduler.
func (s *Scheduler) Run(ctx context.Context, wg *sync.WaitGroup) {
	defer wg.Done()

	go s.runTaskCompletionListener(ctx)

	// Start rollout creator component
	rolloutCreator := NewRolloutCreator(s.store, s.bus, s.webhookManager)
	wg.Add(3)
	go rolloutCreator.Run(ctx, wg, s.bus.RolloutCreationChan)
	go s.runPendingTaskRunsScheduler(ctx, wg)
	go s.runRunningTaskRunsScheduler(ctx, wg)

	slog.Debug("Task scheduler V2 started with independent runners")
	<-ctx.Done()
}

func (s *Scheduler) runTaskCompletionListener(ctx context.Context) {
	defer func() {