fix schedule-manager entry clean-up (#666)

miklezzzz · web-flow · commit cd4231849635 · 2024-10-14T20:52:23.000+04:00
Signed-off-by: Mikhail Scherba &lt;mikhail.scherba@flant.com&gt;
diff --git a/pkg/schedule_manager/schedule_manager.go b/pkg/schedule_manager/schedule_manager.go
@@ -104,6 +104,7 @@ func (sm *scheduleManager) Remove(delEntry ScheduleEntry) {
 	// if all ids are deleted, stop scheduled function
 	if len(sm.Entries[delEntry.Crontab].Ids) == 0 {
 		sm.cron.Remove(sm.Entries[delEntry.Crontab].EntryID)
+		delete(sm.Entries, delEntry.Crontab)
 		log.WithField("operator.component", "scheduleManager").Debugf("entry '%s' deleted", delEntry.Crontab)
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -104,6 +104,7 @@ func (sm *scheduleManager) Remove(delEntry ScheduleEntry) {`
`104`	`104`	`// if all ids are deleted, stop scheduled function`
`105`	`105`	`if len(sm.Entries[delEntry.Crontab].Ids) == 0 {`
`106`	`106`	`sm.cron.Remove(sm.Entries[delEntry.Crontab].EntryID)`
	`107`	`+ delete(sm.Entries, delEntry.Crontab)`
`107`	`108`	`log.WithField("operator.component", "scheduleManager").Debugf("entry '%s' deleted", delEntry.Crontab)`
`108`	`109`	`}`
`109`	`110`	`}`