diff --git a/internal/tasks/processEvents.go b/internal/tasks/processEvents.go index 83d521f..0489074 100644 --- a/internal/tasks/processEvents.go +++ b/internal/tasks/processEvents.go @@ -69,6 +69,13 @@ func (c *CronTask) RunVmCheck(ctx context.Context, logger *slog.Logger) error { c.Logger.Debug("Simulate adding to Inventory", "vm_name", evt.VmName.String, "vcpus", numVcpus, "ram", numRam, "dc", datacenter) + // mark this event as processed + err = c.Database.Queries().UpdateEventsProcessed(ctx, evt.Eid) + if err != nil { + c.Logger.Error("Unable to mark this event as processed", "event_id", evt.Eid, "error", err) + } else { + c.Logger.Debug("Marked event as processed", "event_id", evt.Eid) + } } //fmt.Printf("processing at %s", time.Now())