From b9eaff36882e6ddf9fbe33671544bfbc27f7dc56 Mon Sep 17 00:00:00 2001
From: Pyra <92104930+pyranota@users.noreply.github.com>
Date: Wed, 22 Oct 2025 09:15:28 +0200
Subject: [PATCH] debouncing edge case (#6891)

* fix: debouncing edge case

* Update SQLx metadata

---------

Co-authored-by: windmill-internal-app[bot] <windmill-internal-app[bot]@users.noreply.github.com>
---
 ...d1b708657f01c8fb26e81e78807315226557f08449bf43982abb.json} | 4 ++--
 backend/windmill-queue/src/jobs.rs                            | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
 rename backend/.sqlx/{query-7ed404f3a8b23f98fb7c15a26b14f9e3e416e1baf20bdb25c9a8ac9efc288931.json => query-44bf04fb504cd1b708657f01c8fb26e81e78807315226557f08449bf43982abb.json} (63%)

diff --git a/backend/.sqlx/query-7ed404f3a8b23f98fb7c15a26b14f9e3e416e1baf20bdb25c9a8ac9efc288931.json b/backend/.sqlx/query-44bf04fb504cd1b708657f01c8fb26e81e78807315226557f08449bf43982abb.json
similarity index 63%
rename from backend/.sqlx/query-7ed404f3a8b23f98fb7c15a26b14f9e3e416e1baf20bdb25c9a8ac9efc288931.json
rename to backend/.sqlx/query-44bf04fb504cd1b708657f01c8fb26e81e78807315226557f08449bf43982abb.json
index 9216f73a7e..9f0e810e97 100644
--- a/backend/.sqlx/query-7ed404f3a8b23f98fb7c15a26b14f9e3e416e1baf20bdb25c9a8ac9efc288931.json
+++ b/backend/.sqlx/query-44bf04fb504cd1b708657f01c8fb26e81e78807315226557f08449bf43982abb.json
@@ -1,6 +1,6 @@
 {
   "db_name": "PostgreSQL",
-  "query": "INSERT INTO debounce_key (key, job_id) VALUES ($1, $2)",
+  "query": "INSERT INTO debounce_key (key, job_id) VALUES ($1, $2) ON CONFLICT (key) DO UPDATE SET job_id = EXCLUDED.job_id",
   "describe": {
     "columns": [],
     "parameters": {
@@ -11,5 +11,5 @@
     },
     "nullable": []
   },
-  "hash": "7ed404f3a8b23f98fb7c15a26b14f9e3e416e1baf20bdb25c9a8ac9efc288931"
+  "hash": "44bf04fb504cd1b708657f01c8fb26e81e78807315226557f08449bf43982abb"
 }
diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs
index b3d34ee8cb..19ac7bb28c 100644
--- a/backend/windmill-queue/src/jobs.rs
+++ b/backend/windmill-queue/src/jobs.rs
@@ -4590,7 +4590,7 @@ pub async fn push<'c, 'd>(
                 );
 
                 sqlx::query!(
-                    "INSERT INTO debounce_key (key, job_id) VALUES ($1, $2)",
+                    "INSERT INTO debounce_key (key, job_id) VALUES ($1, $2) ON CONFLICT (key) DO UPDATE SET job_id = EXCLUDED.job_id",
                     &debounce_key,
                     job_id,
                 )