From 2f6cd6d65996a58e1f4619ecb23a763ebbfa02d2 Mon Sep 17 00:00:00 2001 From: Ta-Ching Chen Date: Wed, 31 May 2017 05:21:41 +0800 Subject: [PATCH] Print log when timetrigger is removed (#209) --- timer/timer.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/timer/timer.go b/timer/timer.go index 03a73b55..1b61544d 100644 --- a/timer/timer.go +++ b/timer/timer.go @@ -17,10 +17,10 @@ limitations under the License. package timer import ( - "github.com/robfig/cron" - "log" + "github.com/robfig/cron" + "github.com/fission/fission" "github.com/fission/fission/publisher" ) @@ -121,6 +121,7 @@ func (timer *Timer) syncCron(triggers []fission.TimeTrigger) error { if !found { if v.cron != nil { v.cron.Stop() + log.Printf("Cron for time trigger %s stopped", v.trigger.Name) } delete(timer.triggers, k) } @@ -138,6 +139,6 @@ func (timer *Timer) newCron(t fission.TimeTrigger) *cron.Cron { (*timer.publisher).Publish("", headers, fission.UrlForFunction(&t.Function)) }) c.Start() - log.Printf("Updated new cron for %v", t.Name) + log.Printf("Add new cron for time trigger %v", t.Name) return c }