update

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())