(ctx context.Context)
| 663 | } |
| 664 | |
| 665 | func (s *Scheduler) starting(ctx context.Context) error { |
| 666 | s.subservicesWatcher.WatchManager(s.subservices) |
| 667 | |
| 668 | if err := services.StartManagerAndAwaitHealthy(ctx, s.subservices); err != nil { |
| 669 | return errors.Wrap(err, "unable to start scheduler subservices") |
| 670 | } |
| 671 | |
| 672 | return nil |
| 673 | } |
| 674 | |
| 675 | func (s *Scheduler) running(ctx context.Context) error { |
| 676 | for { |
nothing calls this directly
no test coverage detected