fix: don't skip locked on updating worker

hatchet-dev · Aug 6, 2024 · 45b1869 · 45b1869
1 parent 6b3f402
commit 45b1869
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 20 deletions.
diff --git a/pkg/repository/prisma/dbsqlc/workers.sql b/pkg/repository/prisma/dbsqlc/workers.sql
@@ -124,22 +124,13 @@ INSERT INTO "Worker" (
 ) RETURNING *;
 
 -- name: UpdateWorkerHeartbeat :one
-WITH to_update AS (
-    SELECT
-        "id"
-    FROM
-        "Worker"
-    WHERE
-        "id" = @id::uuid
-    FOR UPDATE SKIP LOCKED
-)
 UPDATE
     "Worker"
 SET
     "updatedAt" = CURRENT_TIMESTAMP,
     "lastHeartbeatAt" = sqlc.narg('lastHeartbeatAt')::timestamp
 WHERE
-    "id" IN (SELECT "id" FROM to_update)
+    "id" = @id::uuid
 RETURNING *;
 
 -- name: UpdateWorker :one

diff --git a/pkg/repository/prisma/dbsqlc/workers.sql.go b/pkg/repository/prisma/dbsqlc/workers.sql.go