fix: playbook run duplicates

playbook/run_consumer.go

@@ -299,12 +299,13 @@ func RunConsumer(ctx context.Context) (int, error) {
 	FROM playbook_runs
 	INNER JOIN playbooks ON playbooks.id = playbook_runs.playbook_id
 	WHERE status IN (?, ?) AND scheduled_time <= NOW()
+	AND agent_id = ?
 	ORDER BY scheduled_time
 	FOR UPDATE SKIP LOCKED
 	LIMIT 1
 `
 		var run models.PlaybookRun
-		if err := tx.Raw(query, models.PlaybookRunStatusScheduled, models.PlaybookRunStatusSleeping).First(&run).Error; err != nil {
+		if err := tx.Raw(query, models.PlaybookRunStatusScheduled, models.PlaybookRunStatusSleeping, uuid.Nil).First(&run).Error; err != nil {
 			if errors.Is(err, gorm.ErrRecordNotFound) {
 				return nil
 			}