fix timezone bug (#321)

argoproj · Jul 31, 2019 · 4c0d5ed · 4c0d5ed
1 parent 0d7e986
commit 4c0d5ed
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/gateways/core/calendar/start.go b/gateways/core/calendar/start.go
@@ -102,8 +102,9 @@ func (ese *CalendarEventSourceExecutor) listenEvents(cal *calSchedule, eventSour
 	}
 
 	lastT := time.Now()
+	var location *time.Location
 	if cal.Timezone != "" {
-		location, err := time.LoadLocation(cal.Timezone)
+		location, err = time.LoadLocation(cal.Timezone)
 		if err != nil {
 			errorCh <- err
 			return
@@ -122,6 +123,9 @@ func (ese *CalendarEventSourceExecutor) listenEvents(cal *calSchedule, eventSour
 		select {
 		case tx := <-timer:
 			lastT = tx
+			if location != nil {
+				lastT = lastT.In(location)
+			}
 			response := &calResponse{
 				EventTime:   tx,
 				UserPayload: cal.UserPayload,