master
Orchestrator.Run
func (r *Orchestrator) Run(ctx context.Context) error { defer close(r.doneChan) // Watch changes to services and tasks queue := r.store.WatchQueue()