func()

in internal/schedule/inline_scheduler.go [52:66]

• 14 lines of code
• 3 McCabe index (conditional complexity)

func (s *inlineScheduler) Run() {
	go func() {
		ticker := time.NewTicker(time.Millisecond * time.Duration(config.Get().Flow.Scheduler.Interval))
		defer func() {
			if err := recover(); err != nil {
				log.Get(constants.LogSchedule).Errorf("schedule run error=%+v", err)
			}
			ticker.Stop()
		}()

		for range ticker.C {
			s.handle()
		}
	}()
}