diff --git a/scheduler/scheduler.go b/scheduler/scheduler.go index e5819c0..94051b1 100644 --- a/scheduler/scheduler.go +++ b/scheduler/scheduler.go @@ -167,6 +167,7 @@ func (s *scheduler) Schedule(session *types.Session) error { scheduledSession := s.register(session) ctx, cancel := context.WithCancel(context.Background()) scheduledSession.cancel = cancel + scheduledSession.ticker = time.NewTicker(1 * time.Second) go s.cron(ctx, scheduledSession) return nil }