fix: remove join in currency queries (#3294)

* fix: remove join in currency queries

* chore: generate

Author: grutt

examples/python/guides/pyproject.toml

@@ -6,7 +6,7 @@ package-mode = false
 
 [tool.poetry.dependencies]
 python = "^3.10"
-hatchet-sdk = "^1.28.2"
+hatchet-sdk = "^1.29.0"
 # LLM integrations
 openai = "^1.0.0"
 anthropic = "^0.39.0"

examples/typescript/guides/package.json

@@ -8,7 +8,7 @@
     "lint:fix": "eslint . --fix"
   },
   "dependencies": {
-    "@hatchet-dev/typescript-sdk": "^1.16.0",
+    "@hatchet-dev/typescript-sdk": "^1.17.0",
     "@anthropic-ai/sdk": "^0.32.1",
     "@ai-sdk/openai": "^1.0.0",
     "@browserbasehq/sdk": "^2.7.0",

pkg/repository/sqlcv1/concurrency.sql

@@ -323,24 +323,16 @@ WITH locked_workflow_concurrency_slots AS (
     ORDER BY strategy_id, workflow_version_id, workflow_run_id
     FOR UPDATE
 ), eligible_running_slots AS (
-    SELECT wsc.*
+    SELECT *
     FROM (
-        SELECT DISTINCT key
+        SELECT *,
+            ROW_NUMBER() OVER (PARTITION BY key ORDER BY sort_id DESC) as rn
         FROM locked_workflow_concurrency_slots
         WHERE
             tenant_id = @tenantId::uuid
             AND strategy_id = @strategyId::bigint
-    ) distinct_keys
-    JOIN LATERAL (
-        SELECT *
-        FROM locked_workflow_concurrency_slots wcs_all
-        WHERE
-            wcs_all.key = distinct_keys.key
-            AND wcs_all.tenant_id = @tenantId::uuid
-            AND wcs_all.strategy_id = @strategyId::bigint
-        ORDER BY wcs_all.sort_id DESC
-        LIMIT @maxRuns::int
-    ) wsc ON true
+    ) ranked
+    WHERE rn <= @maxRuns::int
 ), slots_to_run AS (
     SELECT
         *
@@ -565,24 +557,16 @@ WITH locked_workflow_concurrency_slots AS (
     ORDER BY strategy_id, workflow_version_id, workflow_run_id
     FOR UPDATE
 ), eligible_running_slots AS (
-    SELECT wsc.*
+    SELECT *
     FROM (
-        SELECT DISTINCT key
+        SELECT *,
+            ROW_NUMBER() OVER (PARTITION BY key ORDER BY sort_id ASC) as rn
         FROM locked_workflow_concurrency_slots
         WHERE
             tenant_id = @tenantId::uuid
             AND strategy_id = @strategyId::bigint
-    ) distinct_keys
-    JOIN LATERAL (
-        SELECT *
-        FROM locked_workflow_concurrency_slots wcs_all
-        WHERE
-            wcs_all.key = distinct_keys.key
-            AND wcs_all.tenant_id = @tenantId::uuid
-            AND wcs_all.strategy_id = @strategyId::bigint
-        ORDER BY wcs_all.sort_id ASC
-        LIMIT @maxRuns::int
-    ) wsc ON true
+    ) ranked
+    WHERE rn <= @maxRuns::int
 ), slots_to_run AS (
     SELECT
         *