# HG changeset patch # User Sascha L. Teichmann # Date 1544557631 -3600 # Node ID 6869eb94ead2e55785970ecb6f517e83a033a6fd # Parent a3c2b192daa22cded35d22b6c435fb73c93e7eca Don't error if an action is not defined if bound. diff -r a3c2b192daa2 -r 6869eb94ead2 pkg/scheduler/scheduler.go --- a/pkg/scheduler/scheduler.go Tue Dec 11 16:13:37 2018 +0100 +++ b/pkg/scheduler/scheduler.go Tue Dec 11 20:47:11 2018 +0100 @@ -44,6 +44,8 @@ func (ua *userAction) Run() { if a := ua.scheduler.action(ua.name); a != nil { a(ua.user, ua.cfgID) + } else { + log.Printf("warn: scheduled action '%s' not found.", ua.name) } } @@ -70,8 +72,8 @@ // UnbindAction unbinds a named action from a user and // an optional configuration id. -func UnbindAction(name, user string, cfgID *int64) error { - return global.unbindAction(name, user, cfgID) +func UnbindAction(name, user string, cfgID *int64) { + global.unbindAction(name, user, cfgID) } // UnbindUser unbinds all schedules for a given user. @@ -127,7 +129,7 @@ s.cr.Start() } -func (s *scheduler) unbindAction(name, user string, cfgID *int64) error { +func (s *scheduler) unbindAction(name, user string, cfgID *int64) { s.mu.Lock() defer s.mu.Unlock() @@ -144,7 +146,7 @@ } if found == nil { - return ErrNoSuchAction + return } s.cr.Stop() @@ -156,8 +158,6 @@ } } s.cr.Start() - - return nil } func (s *scheduler) bindAction(name, spec, user string, cfgID *int64) error { @@ -170,11 +170,6 @@ s.mu.Lock() defer s.mu.Unlock() - action := s.actions[name] - if action == nil { - return ErrNoSuchAction - } - entries := s.cr.Entries() var found *userAction